Skip to content

连接数据库并执行SQL语句

#!/usr/bin/python3
import xgcondb

conn = xgcondb.connect(host="127.0.0.1", port="5138", database="SYSTEM", user="SYSDBA", password="SYSDBA") 
cur = conn.cursor()
try:
        # execute()
        print("execute()")
        cur.execute("CREATE TABLE TAB_FETCHONE_TEST1(A INT, B INT, C VARCHAR, D DATETIME, E NUMBER(4,2))")
        cur.execute("INSERT INTO TAB_FETCHONE_TEST1 VALUES(1001,2001,'Xugu1','2019-01-01',23.54);")
        cur.execute("INSERT INTO TAB_FETCHONE_TEST1 VALUES(1002,2002,'Xugu2','2019-01-02',2.354);")
        cur.execute("INSERT INTO TAB_FETCHONE_TEST1 VALUES(1003,2003,'Xugu3','2019-01-03',35.4);")
        cur.execute("INSERT INTO TAB_FETCHONE_TEST1 VALUES(1004,2004,'Xugu4','2019-01-04',54.00);")
        cur.execute("SELECT * FROM TAB_FETCHONE_TEST1;")
        row = cur.fetchone()
        while row is not None:
            print(row)
        row = cur.fetchone()
        print()
        cur.execute("SELECT * FROM TAB_FETCHONE_TEST1;")
        row = cur.fetchone()
        print(row) 
        print(cur.fetchone())
        print(cur.fetchone())

        # executemany()
        print("executemany()")
        cur.executemany("SELECT * FROM TAB_FETCHONE_TEST1;")
        row = cur.fetchone()
        while row is not None:
          print(row)
          row = cur.fetchone()
        print()
        cur.executemany("SELECT * FROM TAB_FETCHONE_TEST1;")
        row = cur.fetchone()
        print(row) 
        print(cur.fetchone())