Skip to content

大对象的插入与导出

#!/usr/bin/python3
import xgcondb

## 建立数据库连接,客户端与数据库连接字符集默认GBK,可以设置 UTF8
conn = xgcondb.connect(host="127.0.0.1", port="5138", database="SYSTEM", user="SYSDBA", password="SYSDBA",charset="GBK")
## 创建连接的游标
cur = conn.cursor()
cur.execute('create table t_lob(B BLOB, C CLOB);')
#---------------------大对象插入--------------------
clob_fp = open("./clob_test.txt","r")
blob_fp = open("./blob_test.jpg","rb")
clob_buf = clob_fp.read()
blob_buf = blob_fp.read()
cur.execute('insert into t_lob values(?,?);',(blob_buf,clob_buf))

#---------------------大对象导出--------------------
cur.execute('select * from t_lob;')
row = cur.fetchone()
clob_fd = open("./clob_select.txt","w+")
blob_fd = open("./blob_select.jpg","wb+")
blob_fd.write(row[0])
clob_fd.write(row[1])
cur.close()
conn.close()