Question

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

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

Answer 1

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()

Answer 2

要读多少条数据？

追问

每次一条数据