GBase8a Sqlalchemy 调试

curl https://bootstrap.pypa.io/get-pip.py -o get-pip.py

python3 get-pip.py

pip3 install SQLalchemy

pip3 install pymysql

cd /usr/local/lib/python3.6/site-packages/sqlalchemy/dialects/mysql

vi base.py

原来的代码

GBase 不支持 transaction_isolation，所以代码增加

cursor.execute("SELECT @@tx_isolation")

修改后的代码如下，对GBase版本号进行判断

from sqlalchemy import create_engine                  # 从sqlalchemy 导入创建引擎这个模块

engine = create_engine("mysql+pymysql://gbase:gbase20110531@172.16.3.150:5258/test",max_overflow=5)

#operate native sql

engine.execute(

     "INSERT INTO t1 VALUES (2, 10)"

)

engine.execute(

     "INSERT INTO t1 (a, b) VALUES (%s, %s)",

    ((555, 1212),(666, 3223),)

)

engine.execute(

    "INSERT INTO t1 (a, b) VALUES (%(id)s, %(name)s)",

    id=999, name=888

)

conn = engine.connect()

result = conn.execute("select * from test.t1")

#print(result.to)

rs=result.fetchall()

for r in rs:

        print(r)

creat database test;

create table t1(a int, b int);

python3 gbasetest.py

(9, 5, 3, 16, 115623)

(2, 10)

(555, 1212)

(666, 3223)

(999, 888)