Python连接Kingbase的实现示例

pip install psycopg2
pip3 install psycopg2

yum install python3-devel postgresql-devel*
pip3 install psycopg2

tar xf v8r6_python3.6.8_for_ksycopg2_x86_64.tar.gz -C /usr/local/lib64/python3.6/site-packages

vi /etc/ld.so.conf

/usr/sbin/ldconfig

class KingbaseDb():
    def __init__(self, host, passwd, db):
        try:
            self.conn = ksycopg2.connect(
                host=host,
                port=54321,
                user='root',
                password=passwd,
                database=db
            )
            self.cur = self.conn.cursor()
        except ksycopg2.Error as err:
            logger.error(err)
            sys.exit(-1)

    def __del__(self):
        try:
            self.cur.close()
            self.conn.close()
        except AttributeError:
            pass

    def execute_db(self, sqls):
        try:
            if isinstance(sqls, list):
                for sql in sqls:
                    self.cur.execute(sql)
            else:
                self.cur.execute(sqls)

            self.conn.commit()
        except Exception as e:
            logger.warning(e)
            self.conn.rollback()