声明
该仓库已处于归档状态，后期迭代或提问移步：https://gitee.com/opengauss/openGauss-connector-python-pyog
关于
该驱动是基于 py-postgresql 1.3.0 版本进行修改的，新增了两个特性：
- 支持 openGauss 数据库连接
- 支持多 IP 连接
安装方式
通过 pypi.org:
$ pip install py-opengauss
通过源码安装：
$ git clone https://github.com/vimiix/py-opengauss.git
$ cd py-opengauss
$ python3 setup.py install
连接方式：
支持的连接协议列表: ['pq', 'postgres', 'postgresql', 'og', 'opengauss']
>>> import py_opengauss
# General Format:
>>> db = py_opengauss.open('pq://user:password@host:port/database')
# Also support opengauss scheme:
>>> db = py_opengauss.open('opengauss://user:password@host:port/database')
# multi IP support, will return PRIMARY instance connect:
>>> db = py_opengauss.open('opengauss://user:password@host1:123,host2:456/database')
# Connect to 'postgres' at localhost.
>>> db = py_opengauss.open('localhost/postgres')基本用法
import py_opengauss
db = py_opengauss.open('opengauss://user:password@host:port/database')
get_table = db.prepare("SELECT * from information_schema.tables WHERE table_name = $1")
print(get_table("tables"))
# Streaming, in a transaction.
with db.xact():
for x in get_table.rows("tables"):
print(x)sqlalchemy 多IP连接用法
注：sqlalchemy 目前本身是不支持 py_opengauss 包的
由于 sqlalchemy 在内部会解析连接串，且目前仅支持单个IP的连接串。 所以需下载定制后的 sqlalchemy 手动安装使用
https://github.com/vimiix/sqlalchemy
该定制版本在内部增加了对于 py_opengauss 包的支持，且支持了多IP连接串。
使用方式
from sqlalchemy import create_engine
# 初始化opengauss数据库多主机连接（适用于没有固定虚拟IP的数据库主备集群）:
engine = create_engine('postgresql+pyopengauss://user:password@host1:port1,host2:port2/db')Documentation
http://py-postgresql.readthedocs.io
