C# connection string for Databricks
console application program:
connection string will be:
Driver={Simba Spark ODBC Driver};Host=adb-****.azuredatabricks.net;Port=443;ThriftTransport=2;AuthMech=3;UID=token;PWD=yourgenerated_tokenhere;HTTPPath=/sql/1.0/warehouses/******;SSL=1
Code here
internal class Program
{
static void Main(string[] args)
{
ExecuteQuery();
}
public static void ExecuteQuery()
{
string dsn = "dsn=Databricks_QA";
OdbcConnectionStringBuilder builder = new OdbcConnectionStringBuilder();
builder.Driver = "{Simba Spark ODBC Driver}"; // Or the exact name of your installed Databricks ODBC driver
builder.Add("Host", "adb-******.azuredatabricks.net");
builder.Add("Port", "443"); // Standard port for HTTPS
builder.Add("ThriftTransport", "2");
builder.Add("AuthMech", "3"); // For Personal Access Token authentication
builder.Add("UID", "token");
builder.Add("PWD", "<90 days token heredapi fsflkdf>");
builder.Add("HTTPPath", "/sql/1.0/warehouses/*****");
builder.Add("SSL", "1"); // Enable SSL/TLS
string connectionString = builder.ConnectionString;
using (OdbcConnection connection = new OdbcConnection(builder.ConnectionString))
//using (OdbcConnection connection = new OdbcConnection(dsn))
{
string s = connection.ConnectionString;
//connection.Open();
string qry = "SELECT top 100 * FROM ud_employee.text_data where emp_id='123'";
using (OdbcCommand command = new OdbcCommand(qry, connection))
{
OdbcDataAdapter da = new OdbcDataAdapter(command);
DataSet dataSet = new DataSet();
da.Fill(dataSet);
string test = "dv";
//using (OdbcDataReader reader = command.ExecuteReader())
//{
// while (reader.Read())
// {
// Console.WriteLine(reader["emp_name"]);
// }
//}
}
}
}
}
