python2.7 psycopg2

 psycopg2 安裝

 

sql='''INSERT INTO "CNYB"."PRE_DQ_PLANT"("ID", "ORG_ID", "RT_ORG_ID", "DATE", "DTIME", "CTIME", "INDEX", "MARK", "FNAME", "P_PR", "P_PTR")
VALUES (%(ID)s, %(ORG_ID)s, %(RT_ORG_ID)s, %(DATE)s, %(DTIME)s, %(CTIME)s, %(INDEX)s, %(MARK)s, %(FNAME)s, %(P_PR)s,%(P_PTR)s);'''

util.inserDataToDB(dbcnyb,sql,ret)
sql='''INSERT INTO "CNYB"."PRE_DQ_PLANT"("ID", "ORG_ID", "RT_ORG_ID", "DATE", "DTIME", "CTIME", "INDEX", "MARK", "FNAME", "P_PR", "P_PTR")
VALUES ('%(ID)s', '%(ORG_ID)s', '%(RT_ORG_ID)s', '%(DATE)s', '%(DTIME)s', '%(CTIME)s', '%(INDEX)s', '%(MARK)s', '%(FNAME)s', '%(P_PR)s','%(P_PTR)s');'''

retlist=[]
for rd in ret:
    new_sql=sql%rd
    retlist.append(new_sql)
newsql=';'.join(retlist)
util.inserDataToDB2(dbcnyb,newsql)

 

def inserDataToDB(cnyb,sql,rows):
    try:
        stime=datetime.datetime.now()
        with  cnyb.cursor() as cur:
            cur.executemany(sql, rows)
            cnyb.commit()
            LOG.debug("insert over")
        etime=datetime.datetime.now()
        gap=(stime-etime).seconds
        LOG.debug('gap=%s'%gap)
    except Exception,e:
        cnyb.rollback()
        LOG.error("insert data fail，ex=%s"%(traceback.format_exc()))

def inserDataToDB2(cnyb,sql):
    try:
        stime=datetime.datetime.now()
        with  cnyb.cursor() as cur:
            cur.execute(sql)
            cnyb.commit()
            LOG.debug("insert over")
        etime=datetime.datetime.now()
        gap=(stime-etime).seconds
        LOG.debug('gap2=%s'%gap)
    except Exception,e:
        cnyb.rollback()
        LOG.error("insert data fail，ex=%s"%(traceback.format_exc()))
==================

util.inserDataToDB(dbcnyb,'"CNYB"."PRE_DQ_PLANT"',uncoverData,['ID', 'ORG_ID', 'RT_ORG_ID', 'DATE', 'DTIME', 'CTIME', 'INDEX', 'MARK', 'FNAME', 'P_PR','P_PTR'])

def inserDataToDB(cnyb,tbl,df,cols):
    try:
        output = BytesIO()
        df.to_csv(output, sep='\t', index=False, header=False,columns=cols)
        stime=time.clock()
        with  cnyb.cursor() as cur:
            cur.copy_from(output, tbl)            cnyb.commit()        etime=time.clock()        LOG.debug("insert over,insert sends=%s"%(etime-stime))    except Exception,e:        cnyb.rollback()        LOG.error("insert data fail，ex=%s"%(traceback.format_exc()))