本文介绍如何通过MySQL的.NET connector连接AnalyticDB for MySQL。

using System;
using System.Data;
using MySql.Data;
using MySql.Data.MySqlClient;
namespace adbdemo
{
    public class Tutorial2
    {
        public static void Main()
        {
    //server是AnalyticDB for MySQL集群的连接地址URL，可以在控制台的集群信息页面获取连接URL。
    //UID是AnalyticDB for MySQL集群中的用户账号：高权限账号或者普通账号。
    //database是AnalyticDB for MySQL集群中的数据库名称。
    //port是AnalyticDB for MySQL集群连接端口号。
    //password是AnalyticDB for MySQL集群中用户账号对应的密码。
            string connStr = "server=...;UID=...;database=...;port=...;password=...;SslMode=none;";
            MySqlConnection conn = new MySqlConnection(connStr);
            try
            {
                Console.WriteLine("Connecting to MySQL...");
                conn.Open();
                string sql = "select c_custkey, c_name from customer limit 1";
                MySqlCommand cmd = new MySqlCommand(sql, conn);
                MySqlDataReader rdr = cmd.ExecuteReader();
                while (rdr.Read())
                {
                    Console.WriteLine(rdr[0] + " --- " + rdr[]);
                }
                rdr.Close();
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex.ToString());
            }
            conn.Close();
            Console.WriteLine("Done.");
        }
    }
}