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

發行項
08/15/2024

適用於：適用於 MySQL 的 Azure 資料庫 - 彈性伺服器

在本快速入門中，您會使用 Python 連線到適用於 MySQL 的 Azure 資料庫彈性伺服器。接著，您可以使用 SQL 陳述式來查詢、插入、更新和刪除 Mac、Ubuntu Linux 和 Windows 平台中的資料庫所含的資料。

本文假設您已熟悉使用 Python 開發，但不熟悉適用於 MySQL 的 Azure 資料庫彈性伺服器。

必要條件

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

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

準備用戶端工作站

如果您使用私人存取 (VNet 整合) 建立彈性伺服器，就必須從與伺服器相同的 VNet 中的資源連線到您的伺服器。您可以建立虛擬機器，並新增至使用您彈性伺服器建立的 VNet。請參閱使用 Azure CLI 建立和管理適用於 MySQL 的 Azure 資料庫彈性伺服器虛擬網路。
如果您使用公用存取 (允許的 IP 位址)建立彈性伺服器，可以將本機 IP 位址新增至伺服器上的防火牆規則清單。請參閱使用 Azure CLI 建立和管理適用於 MySQL 的 Azure 資料庫彈性伺服器防火牆規則。

安裝 Python 和 MySQL 連接器

使用下列步驟，在您的電腦上安裝 Python 和適用於 Python 的 MySQL 連接器：

注意

本快速入門會使用原始 SQL 查詢方法連線至 MySQL。如果您使用 Web 架構，請為這些架構使用建議的連接器，例如針對 Django 使用 mysqlclient。

為您的作業系統下載並安裝 Python 3.7 或更新版本。請務必將 Python 新增至您的 PATH，因為 MySQL 連接器有此需要。
開啟命令提示字元或 bash 殼層，並以大寫 V 參數執行 python -V，以檢查您的 Python 版本。
最新版的 Python 中會包含 pip 套件安裝程式。請執行 pip install -U pip，以將 pip 更新為最新版本。

若未安裝 pip，您可以使用 get-pip.py 加以下載並安裝。如需詳細資訊，請參閱安裝。
使用 pip 安裝 Python 的 MySQL 連接器及其相依性：
```
pip install mysql-connector-python
```
您也可以從 mysql.com 安裝 MySQL 的 Python 連接器。若要深入了解 Python 的 MySQL 連接器，請參閱 MySQL 連接器/Python 開發人員指南。

取得連線資訊

從 Azure 入口網站取得連線至適用於 MySQL 的 Azure 資料庫彈性伺服器所需的連線資訊。您需要伺服器名稱、資料庫名稱和登入認證。

登入 Azure 入口網站。
在入口網站的搜尋列中，搜尋並選取您所建立的適用於 MySQL 的 Azure 資料庫彈性伺服器執行個體，例如 mydemoserver。
在伺服器的 [概觀] 頁面上，記下 [伺服器名稱] 和 [伺服器管理員登入名稱]。如果您忘記密碼，您也可以從此頁面重設密碼。

程式碼範例

執行以下提及的 Python 程式碼範例

針對本文中的每個程式碼範例：

在文字編輯器中建立新的檔案。
將程式碼範例新增至檔案。在程式碼中，將 <mydemoserver>、<myadmin>、<mypassword> 和 <mydatabase> 預留位置取代為您的 MySQL 伺服器和資料庫的值。
將副檔名為 .py 的檔案儲存到專案資料夾中，例如 C:\pythonmysql\createtable.py 或 /home/username/pythonmysql/createtable.py。
若要執行程式碼，請開啟命令提示字元或 cd pythonmysql 殼層，並將目錄切換至您的專案資料夾，例如 bash。輸入後面接著檔案名稱的 python 命令 (例如 python createtable.py)，然後按 Enter 鍵。

注意

在 Windows 上，如果找不到 python.exe，您可能需要將 Python 路徑新增至 PATH 環境變數中，或提供 python.exe 的完整路徑，例如 C:\python27\python.exe createtable.py。

建立資料表及插入資料

使用下列程式碼搭配 INSERT SQL 陳述式連線至伺服器和資料庫、建立資料表，以並載入資料。

此程式碼會匯入 mysql.connector 程式庫，並使用 connect() 函式搭配 config 集合中的引數連線至彈性伺服器。此程式碼使用連線上的資料指標，而 cursor.execute() 方法會對 MySQL 資料庫執行 SQL 查詢。

import mysql.connector
from mysql.connector import errorcode

# Obtain connection string information from the portal

config = {
  'host':'<mydemoserver>.mysql.database.azure.com',
  'user':'<myadmin>',
  'password':'<mypassword>',
  'database':'<mydatabase>'
}

# Construct connection string

try:
   conn = mysql.connector.connect(**config)
   print("Connection established")
except mysql.connector.Error as err:
  if err.errno == errorcode.ER_ACCESS_DENIED_ERROR:
    print("Something is wrong with the user name or password")
  elif err.errno == errorcode.ER_BAD_DB_ERROR:
    print("Database does not exist")
  else:
    print(err)
else:
  cursor = conn.cursor()

# Drop previous table of same name if one exists
cursor.execute("DROP TABLE IF EXISTS inventory;")
print("Finished dropping table (if existed).")

# Create table
cursor.execute("CREATE TABLE inventory (id serial PRIMARY KEY, name VARCHAR(50), quantity INTEGER);")
print("Finished creating table.")

# Insert some data into table
cursor.execute("INSERT INTO inventory (name, quantity) VALUES (%s, %s);", ("banana", 150))
print("Inserted",cursor.rowcount,"row(s) of data.")
cursor.execute("INSERT INTO inventory (name, quantity) VALUES (%s, %s);", ("orange", 154))
print("Inserted",cursor.rowcount,"row(s) of data.")
cursor.execute("INSERT INTO inventory (name, quantity) VALUES (%s, %s);", ("apple", 100))
print("Inserted",cursor.rowcount,"row(s) of data.")

# Cleanup
conn.commit()
cursor.close()
conn.close()
print("Done.")

讀取資料

使用下列程式碼搭配 SELECT SQL 陳述式來連線和讀取資料。

此程式碼會使用 fetchall() 方法來讀取資料列，並將結果集保存在集合資料列中，然後使用 for 迭代器對資料列執行迴圈。

import mysql.connector
from mysql.connector import errorcode

# Obtain connection string information from the portal

config = {
  'host':'<mydemoserver>.mysql.database.azure.com',
  'user':'<myadmin>',
  'password':'<mypassword>',
  'database':'<mydatabase>'
}

# Construct connection string

try:
   conn = mysql.connector.connect(**config)
   print("Connection established")
except mysql.connector.Error as err:
  if err.errno == errorcode.ER_ACCESS_DENIED_ERROR:
    print("Something is wrong with the user name or password")
  elif err.errno == errorcode.ER_BAD_DB_ERROR:
    print("Database does not exist")
  else:
    print(err)
else:
  cursor = conn.cursor()

  # Read data
  cursor.execute("SELECT * FROM inventory;")
  rows = cursor.fetchall()
  print("Read",cursor.rowcount,"row(s) of data.")

  # Print all rows
  for row in rows:
  	print("Data row = (%s, %s, %s)" %(str(row[0]), str(row[1]), str(row[2])))

  # Cleanup
  conn.commit()
  cursor.close()
  conn.close()
  print("Done.")

更新資料

使用下列程式碼搭配 UPDATE SQL 陳述式來連線和更新資料。

import mysql.connector
from mysql.connector import errorcode

# Obtain connection string information from the portal

config = {
  'host':'<mydemoserver>.mysql.database.azure.com',
  'user':'<myadmin>',
  'password':'<mypassword>',
  'database':'<mydatabase>'
}

# Construct connection string

try:
   conn = mysql.connector.connect(**config)
   print("Connection established")
except mysql.connector.Error as err:
  if err.errno == errorcode.ER_ACCESS_DENIED_ERROR:
    print("Something is wrong with the user name or password")
  elif err.errno == errorcode.ER_BAD_DB_ERROR:
    print("Database does not exist")
  else:
    print(err)
else:
  cursor = conn.cursor()

  # Update a data row in the table
  cursor.execute("UPDATE inventory SET quantity = %s WHERE name = %s;", (200, "banana"))
  print("Updated",cursor.rowcount,"row(s) of data.")

  # Cleanup
  conn.commit()
  cursor.close()
  conn.close()
  print("Done.")

刪除資料

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

import mysql.connector
from mysql.connector import errorcode

# Obtain connection string information from the portal

config = {
  'host':'<mydemoserver>.mysql.database.azure.com',
  'user':'<myadmin>',
  'password':'<mypassword>',
  'database':'<mydatabase>'
}

# Construct connection string

try:
   conn = mysql.connector.connect(**config)
   print("Connection established.")
except mysql.connector.Error as err:
  if err.errno == errorcode.ER_ACCESS_DENIED_ERROR:
    print("Something is wrong with the user name or password.")
  elif err.errno == errorcode.ER_BAD_DB_ERROR:
    print("Database does not exist.")
  else:
    print(err)
else:
  cursor = conn.cursor()

  # Delete a data row in the table
  cursor.execute("DELETE FROM inventory WHERE name=%(param1)s;", {'param1':"orange"})
  print("Deleted",cursor.rowcount,"row(s) of data.")

  # Cleanup
  conn.commit()
  cursor.close()
  conn.close()
  print("Done.")

共用方式為