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

  • Cikk

A következőkre vonatkozik: Azure Database for PostgreSQL – Rugalmas kiszolgáló

Ebben a rövid útmutatóban egy rugalmas Azure Database for PostgreSQL-kiszolgálópéldányhoz 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át, de még nem használta a rugalmas Azure Database for PostgreSQL-kiszolgálót.

Előfeltételek

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

A Python-kódtárak telepítése a PostgreSQL-hez

A psycopg2 modul lehetővé teszi a PostgreSQL-adatbázisokhoz való csatlakozást és lekérdezést, és Linux, macOS vagy Windows rendszerű kerékcsomagként érhető el. Telepítse a modul bináris verzióját, beleértve az összes függőséget is.

A telepítéshez psycopg2nyisson meg egy terminált vagy parancssort, és futtassa a parancsot pip install psycopg2.

Adatbázis-kapcsolat adatainak lekérése

Csatlakozás rugalmas Azure Database for PostgreSQL-kiszolgálópéldányhoz való hozzáféréshez a kiszolgáló teljes neve és bejelentkezési hitelesítő adatai szükségesek. Ezeket az információkat az Azure Portalon szerezheti be.

  1. Az Azure Portalon keresse meg és válassza ki a rugalmas Azure Database for PostgreSQL-kiszolgáló nevét.

  2. A kiszolgáló Áttekintés lapján másolja ki a teljes kiszolgálónevetés a Rendszergazda felhasználónevet. A kiszolgáló teljes neve mindig a my-server-name.postgres.database.azure.com> formátumú<.

    Szüksége van a rendszergazdai jelszavára is. Ha elfelejti, visszaállíthatja az áttekintési oldalról.

A Python-példák futtatása

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 következőt:

    • <server-name> és <admin-username> az Azure Portalról másolt értékekkel.
    • <admin-password> a kiszolgáló jelszavával.
    • <database-name> a rugalmas Azure Database for PostgreSQL-kiszolgálóadatbázis nevével. A kiszolgáló létrehozásakor automatikusan létre lett hozva egy postgres nevű alapértelmezett adatbázis. Átnevezheti az adatbázist, vagy létrehozhat egy új adatbázist SQL-parancsokkal.

  3. Mentse a fájlt a projektmappába . py kiterjesztéssel, például postgres-insert.py. Windows esetén a fájl mentésekor győződjön meg arról, hogy az UTF-8 kódolás ki van választva.

  4. A fájl futtatásához váltson a projektmappára egy parancssori felületen, és írja be python például a fájlnevet python postgres-insert.py.

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

Az alábbi példakód a psycopg2.connect függvény használatával csatlakozik a rugalmas Azure Database for PostgreSQL-kiszolgálóadatbázishoz, és sql IN Standard kiadás RT utasítással tölti be az adatokat. A cursor.execute függvény végrehajtja az SQL-lekérdezést az adatbázison.

import psycopg2

# Update connection string information 
host = "<server-name>"
dbname = "<database-name>"
user = "<admin-username>"
password = "<admin-password>"
sslmode = "require"

# Construct connection string
conn_string = "host={0} user={1} dbname={2} password={3} sslmode={4}".format(host, user, dbname, password, sslmode)
conn = psycopg2.connect(conn_string) 
print("Connection established")
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 a table
cursor.execute("CREATE TABLE inventory (id serial PRIMARY KEY, name VARCHAR(50), quantity INTEGER);")
print("Finished creating table")

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

# Clean up
conn.commit()
cursor.close()
conn.close()

Ha a kód sikeresen fut, a következő kimenetet hozza létre:

Command-line output

Adatok beolvasása

Az alábbi példakód a rugalmas Azure Database for PostgreSQL-kiszolgálóadatbázishoz csatlakozik, és a cursor.execute parancsot használja az SQL Standard kiadás LECT utasítással az adatok olvasásához. Ez a függvény fogadja el a lekérdezést, és visszaad egy eredményhalmazt, amely a cursor.fetchall() használatával iterátumot eredményez.

import psycopg2

# Update connection string information
host = "<server-name>"
dbname = "<database-name>"
user = "<admin-username>"
password = "<admin-password>"
sslmode = "require"

# Construct connection string
conn_string = "host={0} user={1} dbname={2} password={3} sslmode={4}".format(host, user, dbname, password, sslmode)
conn = psycopg2.connect(conn_string) 
print("Connection established")
cursor = conn.cursor()

# Fetch all rows from table
cursor.execute("SELECT * FROM inventory;")
rows = cursor.fetchall()

# 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()

Adatok frissítése

Az alábbi példakód a rugalmas Azure Database for PostgreSQL-kiszolgálóadatbázishoz csatlakozik, és a cursor.execute parancsot használja az SQL UPDATE utasítással az adatok frissítéséhez.

import psycopg2

# Update connection string information
host = "<server-name>"
dbname = "<database-name>"
user = "<admin-username>"
password = "<admin-password>"
sslmode = "require"

# Construct connection string
conn_string = "host={0} user={1} dbname={2} password={3} sslmode={4}".format(host, user, dbname, password, sslmode)
conn = psycopg2.connect(conn_string) 
print("Connection established")
cursor = conn.cursor()

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

# Cleanup
conn.commit()
cursor.close()
conn.close()

Adatok törlése

Az alábbi példakód a rugalmas Azure Database for PostgreSQL-kiszolgálóadatbázishoz csatlakozik, és a cursor.execute parancsot használja az SQL DELETE utasítással a korábban beszúrt leltárelem törléséhez.

import psycopg2

# Update connection string information
host = "<server-name>"
dbname = "<database-name>"
user = "<admin-username>"
password = "<admin-password>"
sslmode = "require"

# Construct connection string
conn_string = "host={0} user={1} dbname={2} password={3} sslmode={4}".format(host, user, dbname, password, sslmode)
conn = psycopg2.connect(conn_string) 
print("Connection established")
cursor = conn.cursor()

# Delete data row from table
cursor.execute("DELETE FROM inventory WHERE name = %s;", ("orange",))
print("Deleted 1 row of data")

# Cleanup
conn.commit()
cursor.close()
conn.close()

Következő lépések

Adatbázis migrálása memóriakép és visszaállítás használatával