快速入門：使用 .NET (C#) 來連線和查詢適用於 MySQL 的 Azure 資料庫中的資料 - 彈性伺服器

發行項
12/18/2024

本快速入門示範如何使用 C# 應用程式來連線到適用於 MySQL 的 Azure 資料庫彈性伺服器執行個體。它會顯示如何使用 SQL 陳述式來查詢、插入、更新和刪除資料庫中的資料。

必要條件

在本快速入門中，您需要：

具有有效訂用帳戶的 Azure 帳戶。

如果您沒有 Azure 訂閱，請在開始之前先建立 Azure 免費帳戶。目前，Azure 免費帳戶可讓您免費試用「適用於 MySQL 的 Azure 資料庫 - 彈性伺服器」12 個月。如需詳細資訊，請參閱使用 Azure 免費帳戶免費試用適用於 MySQL 的 Azure 資料庫 - 彈性伺服器。

使用快速入門建立適用於 MySQL 的 Azure 資料庫彈性伺服器實例：使用 Azure 入口網站建立適用於 MySQL 的 Azure 資料庫實例
或快速入門：如果您沒有 Azure CLI，請使用 Azure CLI 建立適用於 MySQL 的 Azure 資料庫 - 彈性伺服器實例。
根據您使用的是公用或私人存取，完成下列其中一項動作以啟用連線。
建立資料庫和非管理使用者
安裝適用於您平台的 .NET SDK (英文) (Windows、Ubuntu Linux 或 macOS)。

有問題嗎？請告訴我們

建立 C# 專案

在命令提示字元中執行︰

mkdir AzureMySqlExample
cd AzureMySqlExample
dotnet new console
dotnet add package MySqlConnector

取得連線資訊

取得連線到適用於 MySQL 的 Azure 資料庫彈性伺服器執行個體所需的連線資訊。您需要完整的伺服器名稱和登入認證。

登入 Azure 入口網站。
從 Azure 入口網站的左側功能表中，選取 [所有資源]，然後搜尋您所建立的伺服器 (例如 mydemoserver)。
選取伺服器名稱。
從伺服器的 [概觀] 面板，記下 [伺服器名稱] 和 [伺服器管理員登入名稱]。如果您忘記密碼，您也可以從此面板重設密碼。

步驟 1：連線和插入資料

使用下列程式碼搭配 CREATE TABLE 和 INSERT INTO SQL 陳述式來連線及載入資料。程式碼會使用 MySqlConnection 類別的方法：

OpenAsync()，用以建立 MySQL 的連線。
CreateCommand()，可設定 CommandText 屬性
ExecuteNonQueryAsync()，用以執行資料庫命令。

將 Server、Database、UserID 和 Password 參數取代為您在建立伺服器和資料庫時所指定的值。

using System;
using System.Threading.Tasks;
using MySqlConnector;

namespace AzureMySqlExample
{
    class MySqlCreate
    {
        static async Task Main(string[] args)
        {
            var builder = new MySqlConnectionStringBuilder
            {
                Server = "YOUR-SERVER.mysql.database.azure.com",
                Database = "YOUR-DATABASE",
                UserID = "USER",
                Password = "PASSWORD",
                SslMode = MySqlSslMode.Required,
            };

            using (var conn = new MySqlConnection(builder.ConnectionString))
            {
                Console.WriteLine("Opening connection");
                await conn.OpenAsync();

                using (var command = conn.CreateCommand())
                {
                    command.CommandText = "DROP TABLE IF EXISTS inventory;";
                    await command.ExecuteNonQueryAsync();
                    Console.WriteLine("Finished dropping table (if existed)");

                    command.CommandText = "CREATE TABLE inventory (id serial PRIMARY KEY, name VARCHAR(50), quantity INTEGER);";
                    await command.ExecuteNonQueryAsync();
                    Console.WriteLine("Finished creating table");

                    command.CommandText = @"INSERT INTO inventory (name, quantity) VALUES (@name1, @quantity1),
                        (@name2, @quantity2), (@name3, @quantity3);";
                    command.Parameters.AddWithValue("@name1", "banana");
                    command.Parameters.AddWithValue("@quantity1", 150);
                    command.Parameters.AddWithValue("@name2", "orange");
                    command.Parameters.AddWithValue("@quantity2", 154);
                    command.Parameters.AddWithValue("@name3", "apple");
                    command.Parameters.AddWithValue("@quantity3", 100);

                    int rowCount = await command.ExecuteNonQueryAsync();
                    Console.WriteLine(String.Format("Number of rows inserted={0}", rowCount));
                }

                // connection will be closed by the 'using' block
                Console.WriteLine("Closing connection");
            }

            Console.WriteLine("Press RETURN to exit");
            Console.ReadLine();
        }
    }
}

有任何問題嗎？讓我們知道。

步驟 2：讀取資料

使用下列程式碼搭配 SELECT SQL 陳述式來連線和讀取資料。程式碼會使用 MySqlConnection 類別搭配下列方法：

OpenAsync()，用以建立 MySQL 的連線。
CreateCommand()，用以設定 CommandText 屬性。
ExecuteReaderAsync()，用以執行資料庫命令。
ReadAsync()，用以前往結果中的記錄。接下來程式碼會使用 GetInt32 和 GetString 來剖析記錄中的值。

將 Server、Database、UserID 和 Password 參數取代為您在建立伺服器和資料庫時所指定的值。

using System;
using System.Threading.Tasks;
using MySqlConnector;

namespace AzureMySqlExample
{
    class MySqlRead
    {
        static async Task Main(string[] args)
        {
            var builder = new MySqlConnectionStringBuilder
            {
                Server = "YOUR-SERVER.mysql.database.azure.com",
                Database = "YOUR-DATABASE",
                UserID = "USER@YOUR-SERVER",
                Password = "PASSWORD",
                SslMode = MySqlSslMode.Required,
            };

            using (var conn = new MySqlConnection(builder.ConnectionString))
            {
                Console.WriteLine("Opening connection");
                await conn.OpenAsync();

                using (var command = conn.CreateCommand())
                {
                    command.CommandText = "SELECT * FROM inventory;";

                    using (var reader = await command.ExecuteReaderAsync())
                    {
                        while (await reader.ReadAsync())
                        {
                            Console.WriteLine(string.Format(
                                "Reading from table=({0}, {1}, {2})",
                                reader.GetInt32(0),
                                reader.GetString(1),
                                reader.GetInt32(2)));
                        }
                    }
                }

                Console.WriteLine("Closing connection");
            }

            Console.WriteLine("Press RETURN to exit");
            Console.ReadLine();
        }
    }
}

有問題嗎？請告訴我們

步驟 3：更新資料

使用下列程式碼搭配 UPDATE SQL 陳述式來連線和讀取資料。程式碼會使用 MySqlConnection 類別搭配下列方法：

OpenAsync()，用以建立 MySQL 的連線。
CreateCommand()，用以設定 CommandText 屬性
ExecuteNonQueryAsync()，用以執行資料庫命令。

將 Server、Database、UserID 和 Password 參數取代為您在建立伺服器和資料庫時所指定的值。

using System;
using System.Threading.Tasks;
using MySqlConnector;

namespace AzureMySqlExample
{
    class MySqlUpdate
    {
        static async Task Main(string[] args)
        {
            var builder = new MySqlConnectionStringBuilder
            {
                Server = "YOUR-SERVER.mysql.database.azure.com",
                Database = "YOUR-DATABASE",
                UserID = "USER",
                Password = "PASSWORD",
                SslMode = MySqlSslMode.Required,
            };

            using (var conn = new MySqlConnection(builder.ConnectionString))
            {
                Console.WriteLine("Opening connection");
                await conn.OpenAsync();

                using (var command = conn.CreateCommand())
                {
                    command.CommandText = "UPDATE inventory SET quantity = @quantity WHERE name = @name;";
                    command.Parameters.AddWithValue("@quantity", 200);
                    command.Parameters.AddWithValue("@name", "banana");

                    int rowCount = await command.ExecuteNonQueryAsync();
                    Console.WriteLine(String.Format("Number of rows updated={0}", rowCount));
                }

                Console.WriteLine("Closing connection");
            }

            Console.WriteLine("Press RETURN to exit");
            Console.ReadLine();
        }
    }
}

步驟 4：刪除資料

使用下列程式碼搭配 DELETE SQL 陳述式來連線及刪除資料。

程式碼會使用 MySqlConnection 類別搭配下列方法

OpenAsync()，用以建立 MySQL 的連線。
CreateCommand()，用以設定 CommandText 屬性。
ExecuteNonQueryAsync()，用以執行資料庫命令。

將 Server、Database、UserID 和 Password 參數取代為您在建立伺服器和資料庫時所指定的值。

using System;
using System.Threading.Tasks;
using MySqlConnector;

namespace AzureMySqlExample
{
    class MySqlDelete
    {
        static async Task Main(string[] args)
        {
            var builder = new MySqlConnectionStringBuilder
            {
                Server = "YOUR-SERVER.mysql.database.azure.com",
                Database = "YOUR-DATABASE",
                UserID = "USER",
                Password = "PASSWORD",
                SslMode = MySqlSslMode.Required,
            };

            using (var conn = new MySqlConnection(builder.ConnectionString))
            {
                Console.WriteLine("Opening connection");
                await conn.OpenAsync();

                using (var command = conn.CreateCommand())
                {
                    command.CommandText = "DELETE FROM inventory WHERE name = @name;";
                    command.Parameters.AddWithValue("@name", "orange");

                    int rowCount = await command.ExecuteNonQueryAsync();
                    Console.WriteLine(String.Format("Number of rows deleted={0}", rowCount));
                }

                Console.WriteLine("Closing connection");
            }

            Console.WriteLine("Press RETURN to exit");
            Console.ReadLine();
        }
    }
}

清除資源

若要清除在此快速入門期間使用的所有資源，請使用下列命令刪除資源群組：

az group delete \
    --name $AZ_RESOURCE_GROUP \
    --yes

共用方式為

快速入門：使用 .NET (C#) 來連線和查詢適用於 MySQL 的 Azure 資料庫中的資料 - 彈性伺服器

必要條件

建立 C# 專案

取得連線資訊

步驟 1：連線和插入資料

步驟 2：讀取資料

步驟 3：更新資料

步驟 4：刪除資料

清除資源

意見反應

其他資源

共用方式為

快速入門：使用 .NET (C#) 來連線和查詢適用於 MySQL 的 Azure 資料庫中的資料 - 彈性伺服器

必要條件

建立 C# 專案

取得連線資訊

步驟 1：連線和插入資料

步驟 2：讀取資料

步驟 3：更新資料

步驟 4：刪除資料

清除資源

相關內容

意見反應

其他資源