提要: 这个 PostgresQL Python 部分向您展示了如何使用 Python 编程语言来处理 PostgreSQL 数据库。

Python 有很多用于 PostgreSQL 的驱动。其中,最流行的是 psycopg。它完整的实现 Python 的 DB-API 2.0 规范。

psycopg 当前版本是 2,也称为 psycopg2

安装 psycopg2

通过 pip 可以轻松的安装 psycopg2。我们推荐在 venv 虚拟环境下安装。

pip install psycopg2

连接到 PostgreSQL

我们使用PHP接口部分的数据库和数据表进行演示。

然后连接到数据库:

conn = psycopg2.connect("dbname=sjk66 user=postgres password=sjk66.com")

也可以使用下面的方式进行连接:

conn = psycopg2.connect(host="localhost",database="sjk66", user="postgres", password="sjk66.com")

我们新建一个 get_conn() 函数来连接数据库:

import psycopg2

def get_conn():
    conn = psycopg2.connect("dbname=sjk66 user=postgres password=sjk66.com")
    return conn

插入数据

def insert_stock(symbol, company):
    sql = 'INSERT INTO stocks(symbol,company) VALUES(%s,%s)'
    conn = get_conn()
    cur = conn.cursor()
    cur.execute(sql, (symbol, company))
    cur.close()
    conn.close()

修改数据

def update_stock(stock_id, symbol, company):
    sql = 'UPDATE stocks SET company=%s, symbol=%s WHERE id=%s'
    conn = get_conn()
    cur = conn.cursor()
    cur.execute(sql, (company, symbol, stock_id))
    cur.close()
    conn.close()

删除记录

def delete(stock_id):
    sql = 'DELETE FROM stocks  WHERE id=%s'
    conn = get_conn()
    cur = conn.cursor()
    cur.execute(sql, (stock_id,))
    cur.close()
    conn.close()

查询记录

def find_all():
    sql = 'SELECT * FROM stock'
    conn = get_conn()
    cur = conn.cursor()
    cur.execute(sql)
    result = cur.fetchall()
    cur.close()
    conn.close()
    return result
上一篇:PostgreSQL PHP接口
下一篇:PostgreSQL GO接口