Snowflake With C#.Net Core

Once the library is installed you can verify in the Solution Explorer (refer to the below screen).

Step 9. Write the code and logic in the Program.cs file.

You can copy the Main block code and Namespace from the below code snippet. The very important thing is the connection string. You must pass the following information inside the connection string.

• a. Scheme=https
• b. ACCOUNT= bea78282 (it is a snowflake account name that you will get after registering into the snowflake). if the Snowflake URL is “bea78282.us-east-1.snowflakecomputing.com”, then account name will be bea78282. Please change the connection string based on your account.
• c. PORT=443
• d. ROLE=sysadmin (Under which role you want to run your SQL query). It is a Snowflake User role.
• e. WAREHOUSE= compute_wh (Under which virtual warehouse you want to compute your SQL query). It is a warehouse name created under the Snowflake account.
• f. USER=Nitesh (give your Snowflake user name)
• g. PASSWORD=XXXXX (give your Snowflake password)
• h. DB=employeemanagement (the database name where you have table, views, and stored procedure.
• i. SCEHEMA=EM (schema name created under database in Snowflake)

The code snippet is below.

using Snowflake.Data.Client;  
using System;  
namespace SnowflakeWithConsoleApp {  
    class Program {  
        static void Main(string[] args) {  
            string connectionString = "scheme=https;ACCOUNT=bea78282;HOST=bea78282.us-east-1.snowflakecomputing.com;port=443; ROLE=sysadmin;WAREHOUSE=compute_wh; USER=nitesh; PASSWORD=XXXXXXX;DB=employeemanagement;SCHEMA=EM";  
            //Scenario 1. Get the list of employee from Snowflake View which returns Json data  
            using(var conn = new SnowflakeDbConnection()) {  
                conn.ConnectionString = connectionString;  
                conn.Open();  
                var cmd = conn.CreateCommand();  
                cmd.CommandText = "select * from employee_skill_json_view;";  
                var reader = cmd.ExecuteReader();  
                dynamic employeeList;  
                while (reader.Read()) {  
                    Console.WriteLine(reader.GetString(0));  
                    employeeList = reader.GetString(0);  
                }  
                conn.Close();  
            }  
            //Scenario 2. Call the stored procedure employee_insert_json to insert to json data.  
            string inputJsonData = @ "{"  
            "employee_name"  
            ": "  
            "San"  
            ","  
            "employee_address"  
            ": "  
            "Hyderabad"  
            "}";  
            using(var conn = new SnowflakeDbConnection()) {  
                conn.ConnectionString = connectionString;  
                conn.Open();  
                var cmd = conn.CreateCommand();  
                cmd.CommandText = "call employee_insert_json('" + inputJsonData + "'); ";  
                var reader = cmd.ExecuteReader();  
                dynamic resultData;  
                while (reader.Read()) {  
                    Console.WriteLine(reader.GetString(0));  
                    resultData = reader.GetString(0);  
                }  
                conn.Close();  
            }  
        }  
    }  
}  

Step 10. Run your application. You will be getting the below result for the problem statement

Screen for problem statement 1

Screen for problem statement 2

Step 11. To view your SQL query sent by the .Net connector to the Snowflake, you can go to the history and verify the call. I have highlighted the Client Name in the below screen. If you are using a .Net client then It will show .Net. If you are using Snowflake Web Interface, then it will show Snowflake UI.

Conclusion

You can write all the business logic into your stored procedure, View and Function, and connect through Snowflake connector to perform any operation. Now in our case, we can bind the output data directly to the UI screen.

Hope you understand the concept of Snowflake Connector for .Net

Happy Learning!