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

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

首先你必需在本地机安装sybase客户端可以下个sybase anywhere安装好后开始运行的搜索框中输入scjview打开如下工具

点击sybase anywhere的"连接"菜单

点击－－－使用sql Anywhere 11 连接

选中ODBC数据源名->点击下图中的小图标

打开ODBC数据源管理器后－〉点击系统DNS

然后点击添加，进行数据源的添加,然后选择sql Anywhere 11

然后进行sql Anywhere 11的odbc配置

打开sql server 企业管理器安全性－〉链接服务器->新建链接服务器

连接服务器名可以随便取，如果在sql 中查询时，要使用此值查询,例如

select * from openquery(TEST,'select * from test_table')

---