Opérations Python PostgreSQL

Cet article vous présente comment utiliser Python pour faire fonctionner PostgreSQL. Maintenant, je vais le partager ici. Les amis dans le besoin peuvent s'y référer

Python pour faire fonctionner PostgreSQL

Prérequis : ordinateur utilisateur. Base de données PostgreSQL installée sur

Installer psycopg2 –> pip install psycopg2
1. psycopg2.connect(database="testdb", user="postgres", password="cohondob", host="127.0.0.1", port="5432") Cette API ouvre une connexion à la base de données PostgreSQL. Si la base de données est ouverte avec succès, elle renvoie un objet de connexion. www.yibai.com
2. connection.cursor() Ce programme crée un curseur qui sera utilisé pour l'ensemble de la base de données en utilisant la programmation Python. yiibai.com
3. curseur.execute(sql [, paramètres facultatifs]) Cette routine exécute des instructions SQL. Instructions SQL pouvant être paramétrées (c'est-à-dire des espaces réservés, pas des littéraux SQL). Le module psycopg2 prend en charge les espaces réservés marqués par %s yiibai.com Par exemple : curseur.execute("insérer dans les valeurs des personnes (%s, %s)", (qui, âge))
4. curosr.executemany(sql, seq_of_parameters) Ce programme exécute des commandes SQL pour mapper toutes les séquences de paramètres ou SQL dans la séquence. www.yibai.com
5. curosr.callproc(procname[, settings]) Ce programme exécute le programme de base de données de stockage avec le nom donné. Le programme attend une entrée pour chaque argument, et l'ordre des arguments doit en contenir une.
6. Cursor.rowcount est une propriété en lecture seule qui renvoie le nombre total de lignes de la base de données qui ont été modifiées, insérées ou supprimées par la dernière exécution*(). 7. Connection.commit() Cette méthode valide la transaction en cours. Si vous n'appelez pas cette méthode, quelles que soient les modifications apportées depuis le dernier appel à commit(), elles ne seront pas visibles depuis les autres connexions à la base de données.
8. Connection.rollback() Cette méthode annulera toutes les modifications apportées à la base de données depuis le dernier appel de la méthode commit().
9. connection.close() Cette méthode ferme la connexion à la base de données. Notez que cela n'appelle pas automatiquement commit(). Si vous fermez simplement la connexion à la base de données sans appeler au préalable la méthode commit(), toutes les modifications seront perdues ! www.yibai.com
10. Cursor.fetchone() Cette méthode extrait la ligne suivante du jeu de résultats de la requête, renvoyant une séquence, ou rien lorsqu'aucune donnée n'est plus disponible.
11. Cursor.fetchmany([size=cursor.arraysize]) Dans cette routine, le nombre de lignes du résultat de la requête du groupe suivant est supprimé et une liste est renvoyée. Lorsqu'aucun enregistrement n'est trouvé, une liste vide est renvoyée. Cette méthode tente d'obtenir autant de lignes que possible dans le paramètre de taille affiché.
12. Cursor.fetchall() Cette routine obtient toutes les lignes de résultats de requête (restantes) et renvoie une liste. S'il y a une ligne vide, une liste vide est renvoyée. www.yiibai.com

1. Connectez-vous à la base de données

import psycopg2  #导入相关模块
#传入参数 数据库名 用户名 用户密码 主机地址 端口
conn = psycopg2.connect(database="mybase", user="postgres", password="asd123456", host="127.0.0.1", port="5432")

print "Ok"

2. Créez un tableau

import psycopg2

conn = psycopg2.connect(database="mybase", user="postgres", password="asd123456", host="127.0.0.1", port="5432")

cur = conn.cursor() #建立操作游标
#传入的参数是 SQL 建表语句
cur.execute('''CREATE TABLE COMPANY
       (ID INT PRIMARY KEY     NOT NULL,
       NAME           TEXT    NOT NULL,
       AGE            INT     NOT NULL,
       ADDRESS        CHAR(50),
       SALARY         REAL);''')
print "ok"

conn.commit()  #注意，只有commit一下才会生效
conn.close()

3.

4. Supprimer les données

import psycopg2

conn = psycopg2.connect(database="mybase", user="postgres", password="asd123456", host="127.0.0.1", port="5432")

cur = conn.cursor()

#让它ID自动生成
cur.execute("INSERT INTO COMPANY (NAME,AGE,ADDRESS,SALARY) VALUES ( 'Paul', 32, 'California', 20000.00 )");
#注意这里还可以返回插入数据的ID
results = cur.fetchone()
ID = results[0]  #返回插入的记录的id 便于后续操作

conn.commit()
conn.close()

5. Mettre à jour les données

import psycopg2

conn = psycopg2.connect(database="mybase", user="postgres", password="asd123456", host="127.0.0.1", port="5432")

cur = conn.cursor()

cur.execute("DELETE from COMPANY where ID=2;")

conn.commit
conn.close()

6. Interroger les données

import psycopg2

conn = psycopg2.connect(database="mybase", user="postgres", password="asd123456", host="127.0.0.1", port="5432")

cur = conn.cursor()

cur.execute("UPDATE COMPANY set SALARY = 25000.00 where ID=1")
conn.commit
conn.close()

Recommandations associées :

import psycopg2

conn = psycopg2.connect(database="mybase", user="postgres", password="asd123456", host="127.0.0.1", port="5432")

cur = conn.cursor()

cur.execute("SELECT id, name, address, salary  from COMPANY")
rows = cur.fetchall() #这里返回查询的所有数据集
conn.close()

Comment connecter la base de données PostgreSQL avec Python

php utilise l'extension PDO pour se connecter à la base de données relationnelle objet PostgreSQL

php se connecte à postgreSql

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!