Megosztás a következőn keresztül:


Rövid útmutató: Adatok csatlakoztatása és lekérdezése a Python használatával a rugalmas Azure Database for MySQL-kiszolgálón

Ebben a rövid útmutatóban a Rugalmas Azure Database for MySQL-kiszolgálóhoz csatlakozhat a Python használatával. Ezután SQL-utasításokkal lekérdezheti, beszúrhatja, frissítheti és törölheti az adatbázisban lévő adatokat Mac, Ubuntu Linux és Windows platformokról.

Ez a cikk feltételezi, hogy ismeri a Python használatával történő fejlesztést, de még nem használta a rugalmas Azure Database for MySQL-kiszolgálót.

Előfeltételek

  • Egy Azure-fiók, aktív előfizetéssel.

Ha nem rendelkezik Azure-előfizetéssel, a kezdés előtt hozzon létre egy ingyenes Azure-fiókot . Jelenleg ingyenes Azure-fiókkal 12 hónapig ingyenesen kipróbálhatja a Rugalmas Azure Database for MySQL-kiszolgálót. További információ: Ingyenes Azure-fiók használata az Azure Database for MySQL rugalmas kiszolgáló ingyenes kipróbálásához.

Az ügyfél-munkaállomás előkészítése

A Python és a MySQL-összekötő telepítése

Telepítse a Pythont és a Python MySQL-összekötőt a számítógépre az alábbi lépések végrehajtásával:

Feljegyzés

Ez a rövid útmutató nyers SQL-lekérdezési megközelítést használ a MySQL-hez való csatlakozáshoz. Ha webes keretrendszert használ, használja a keretrendszerhez ajánlott összekötőt, például a Django-hoz készült mysqlclientet .

  1. Töltse le és telepítse a Python 3.7-et vagy újabb verziót az operációs rendszerhez. Mindenképpen vegye fel a Pythont a saját PATHfiókjába, mert ehhez a MySQL-összekötő szükséges.

  2. Nyisson meg egy parancssort vagy bash rendszerhéjat, és ellenőrizze a Python-verziót a nagybetűs V kapcsolóval.python -V

  3. A pip csomagtelepítő a Python legújabb verzióiban érhető el. Frissítsen pip a legújabb verzióra a futtatással pip install -U pip.

    Ha pip nincs telepítve, letöltheti és telepítheti a fájllal get-pip.py. További információ: Telepítés.

  4. A Python mySQL-összekötőjének és függőségeinek telepítéséhez használható pip :

    pip install mysql-connector-python
    

    A MySQL-hez készült Python-összekötőt a mysql.com is telepítheti. A Pythonhoz készült MySQL-összekötőről további információt a MySQL Connector/Python fejlesztői útmutatójában talál.

Kapcsolatadatok lekérése

Kérje le a rugalmas Azure Database for MySQL-kiszolgálóhoz való csatlakozáshoz szükséges kapcsolati adatokat az Azure Portalról. Szüksége van a kiszolgáló nevére, az adatbázis nevére és a bejelentkezési hitelesítő adatokra.

  1. Jelentkezzen be az Azure Portalra.

  2. A portál keresősávján keresse meg és válassza ki a létrehozott rugalmas Azure Database for MySQL-kiszolgálópéldányt, például a mydemoservert.

  3. A kiszolgáló Áttekintés lapján jegyezze fel a kiszolgáló nevét és a kiszolgáló rendszergazdai bejelentkezési nevét. Ha elfelejti a jelszavát, ezen a lapon is alaphelyzetbe állíthatja a jelszót.

Kódminták

Futtassa az alábbi Python-kódmintákat

A cikkben szereplő minden kód példánál:

  1. Hozzon létre egy új fájlt egy szövegszerkesztőben.

  2. Adja hozzá a példakódot a fájlhoz. A kódban cserélje le a <mydemoserver>, <myadmin>, <mypassword>és <mydatabase> helyőrzőket a MySQL-kiszolgáló és az adatbázis értékeire.

  3. Mentse a fájlt egy projektmappába egy .py kiterjesztéssel, például C:\pythonmysql\createtable.py vagy /home/username/pythonmysql/createtable.py.

  4. A kód futtatásához nyisson meg egy parancssort vagy bash egy rendszerhéjat, és módosítsa például cd pythonmysqla könyvtárat a projektmappába. Írja be a python parancsot, majd a fájl nevét, például python createtable.py, és nyomja le az Enter billentyűt.

    Feljegyzés

    Windows rendszeren, ha python.exe nem található, előfordulhat, hogy hozzá kell adnia a Python-elérési utat a PATH környezeti változóhoz, vagy meg kell adnia a python.exe teljes elérési útját, példáulC:\python27\python.exe createtable.py.

Tábla létrehozása és adatok beszúrása

A következő kóddal csatlakozhat a kiszolgálóhoz és az adatbázishoz, létrehozhat egy táblát, és adatokat tölthet be egy INSERT SQL utasítással.

A kód importálja a mysql.connector kódtárat, és a connect() függvénnyel csatlakozik a rugalmas kiszolgálóhoz a konfigurációs gyűjtemény argumentumai alapján. A kód egy kurzort használ a kapcsolaton, a cursor.execute() metódus pedig végrehajtja az SQL-lekérdezést a MySQL-adatbázison.

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.")

Adatok beolvasása

A következő kóddal csatlakozhat, és beolvashatja az adatokat a SELECT SQL-utasítással.

A kód importálja a mysql.connector kódtárat, és a connect() függvénnyel csatlakozik a rugalmas kiszolgálóhoz a konfigurációs gyűjtemény argumentumai alapján. A kód egy kurzort használ a kapcsolaton, a cursor.execute() metódus pedig végrehajtja az SQL-lekérdezést a MySQL-adatbázison.

A kód beolvassa az adatsorokat a fetchall() metódussal, megtartja az eredményhalmazt egy gyűjteménysorban, és egy iterátor használatával hurkot hoz for létre a sorok között.

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.")

Adatok frissítése

Az alábbi kód használatával csatlakozhat és végezheti el az adatok módosítását egy UPDATE SQL-utasítás segítségével.

A kód importálja a mysql.connector kódtárat, és a connect() függvénnyel csatlakozik a rugalmas kiszolgálóhoz a konfigurációs gyűjtemény argumentumai alapján. A kód egy kurzort használ a kapcsolaton, a cursor.execute() metódus pedig végrehajtja az SQL-lekérdezést a MySQL-adatbázison.

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.")

Adatok törlése

A következő kód használatával csatlakozhat, és eltávolíthatja az adatokat a DELETE SQL-utasítással.

A kód importálja a mysql.connector kódtárat, és a connect() függvénnyel csatlakozik a rugalmas kiszolgálóhoz a konfigurációs gyűjtemény argumentumai alapján. A kód egy kurzort használ a kapcsolaton, a cursor.execute() metódus pedig végrehajtja az SQL-lekérdezést a MySQL-adatbázison.

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.")