create table test(id int,name varchar2(50))
import cx_Oracleconnect={'ip':'192.168.88.88','port':1521,sid:'orcl',user:'system',password:'oracle'}def oracle_conn(connect, logger): conn = None cursor = None try: dsn = cx_Oracle.makedsn(connect['ip'], connect['port'], connect['sid']) conn = cx_Oracle.connect(connect['user'], connect['password'], dsn) cursor = conn.cursor() except Exception, e: logger.critical(dsn) logger.critical(e) finally: return conn, cursor
import sqlite3sqlite_file='./data.sqlite3'def sqlite_conn(sqlite_file, logger): conn = None cursor = None try: conn = sqlite3.connect(sqlite_file) conn.text_factory = str cursor = conn.cursor() return conn, cursor except Exception, e: print e logger.critical(e) sys.exit(99) finally: return conn, cursor
import pymysqlconnect={'ip':'192.168.88.88','port':3306,user:'root',password:'root','database':'test','charset':'utf8'}def mysql_conn(connec, logger): try: conn = pymysql.connect( host=ip, user=user, password=password, database=database, charset=charset) cursor = conn.cursor() except Exception as e: print e logger.critical(e) sys.exit(99) finally: return conn, cursor
data = [1,'张三']sql = 'insert into test values(:1,:2)'cursor.execute(sql,data)
data = {'id':1,'name':'张三']sql = 'insert into test(id,name) values(:id,:name)'cursor.execute(sql,data)
联系客服