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.
- Rugalmas Azure Database for MySQL-kiszolgálópéldány. Rugalmas Azure Database for MySQL-kiszolgálópéldány létrehozásához tekintse meg a következő rövid útmutatót: Azure Database for MySQL-példány létrehozása az Azure Portallal vagy rövid útmutató: Azure Database for MySQL-példány létrehozása – Rugalmas kiszolgáló létrehozása az Azure CLI használatával.
Az ügyfél-munkaállomás előkészítése
- Ha privát hozzáféréssel (VNet-integrációval ) hozta létre a rugalmas kiszolgálót, a kiszolgálóval azonos virtuális hálózaton belüli erőforrásból kell csatlakoznia a kiszolgálóhoz. Létrehozhat egy virtuális gépet, és hozzáadhatja a rugalmas kiszolgálóval létrehozott virtuális hálózathoz. Tekintse meg az Azure Database for MySQL- rugalmas kiszolgáló virtuális hálózatainak létrehozását és kezelését az Azure CLI használatával.
- Ha nyilvános hozzáféréssel (engedélyezett IP-címekkel ) hozta létre a rugalmas kiszolgálót, hozzáadhatja a helyi IP-címet a kiszolgáló tűzfalszabályainak listájához. Tekintse meg az Azure Database for MySQL tűzfalszabályainak kezelése – Rugalmas kiszolgáló az Azure CLI használatával című témakört.
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 .
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
PATH
fiókjába, mert ehhez a MySQL-összekötő szükséges.Nyisson meg egy parancssort vagy
bash
rendszerhéjat, és ellenőrizze a Python-verziót a nagybetűs V kapcsolóval.python -V
A
pip
csomagtelepítő a Python legújabb verzióiban érhető el. Frissítsenpip
a legújabb verzióra a futtatássalpip install -U pip
.Ha
pip
nincs telepítve, letöltheti és telepítheti a fájllalget-pip.py
. További információ: Telepítés.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.
Jelentkezzen be az Azure Portalra.
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.
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:
Hozzon létre egy új fájlt egy szövegszerkesztőben.
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.Mentse a fájlt egy projektmappába egy .py kiterjesztéssel, például C:\pythonmysql\createtable.py vagy /home/username/pythonmysql/createtable.py.
A kód futtatásához nyisson meg egy parancssort vagy
bash
egy rendszerhéjat, és módosítsa példáulcd pythonmysql
a könyvtárat a projektmappába. Írja be apython
parancsot, majd a fájl nevét, példáulpython 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ául
C:\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.")
Kapcsolódó tartalom
- Csatlakozás rugalmas Azure Database for MySQL-kiszolgálóhoz titkosított kapcsolatokkal
- Kapcsolati és hálózatkezelési fogalmak az Azure Database for MySQL-hez – rugalmas kiszolgáló
- Az Azure Database for MySQL tűzfalszabályainak kezelése – Rugalmas kiszolgáló az Azure Portal használatával
- Virtuális hálózatok létrehozása és kezelése az Azure Database for MySQL-hez – Rugalmas kiszolgáló az Azure Portal használatával