python 读取本地数据然后插入到另一个数据库中

我想实现这样一个功能:
从本地数据库中,读取一组数据,比如 select a.id,a.name from user_info a where a.id='0001';
然后连接到另一个sybase的数据库中,然后插入之前选出的数据,或者直接传sql语句:
insert into sybase_user values('0001','David');
十分感谢!!

class Buffer(object):
    MAXSIZE = 8192
    def __init__(self, conn, sql):
        self.conn = conn
        self.sql = sql
        self.buffer = []
    def append(self, data):
        self.buffer.append(data)
        if len(self.buffer) > self.MAXSIZE:
            self.flush()
    def flush(self):
        data, self.buffer = self.buffer, []
        curr = self.conn.cursor()
        curr.executemany(self.sql, data)
        self.conn.commit()

# here are your code for init database connect conn_src and conn_store...
buff = Buffer(conn_store, "insert into sybase_user values (%s, %s)")
sql_query = "select a.id, a.name from user_info a where a.id=%s"
curr_src = conn_src.cursor()
curr_src.execute(sql_query, '0001')
for row in curr_src:
    buff.append(row)
buff.flush()

温馨提示:答案为网友推荐,仅供参考
第1个回答  2014-11-20
要读多少条数据?追问

每次一条数据

相似回答