create table test(id int,name varchar2(50))

oracle 连接

import cx_Oracle

connect={'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

sqlite 连接

import sqlite3

sqlite_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

mysql 连接

import pymysql

connect={'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)