ETL项目数据库工具开发中切换数据库的代码

以下是一个示例代码，用于在ETL项目中切换数据库。

import pyodbc

# 从源数据库连接
source_con = pyodbc.connect('DRIVER={SQL Server};SERVER=source_server;DATABASE=source_db;UID=username;PWD=password')

# 从目标数据库连接
target_con = pyodbc.connect('DRIVER={SQL Server};SERVER=target_server;DATABASE=target_db;UID=username;PWD=password')

# 执行一些操作，例如从源数据库中选择一些数据并将其插入到目标数据库中
source_cursor = source_con.cursor()
source_cursor.execute('SELECT * FROM source_table')
rows = source_cursor.fetchall()

target_cursor = target_con.cursor()
for row in rows:
    target_cursor.execute('INSERT INTO target_table (column1, column2, column3) VALUES (?, ?, ?)', (row[0], row[1], row[2]))

# 关闭连接
source_cursor.close()
source_con.close()

target_cursor.close()
target_con.close()

在此示例中，我们使用了Python的pyodbc库来连接和操作数据库。我们首先从源数据库连接，然后从目标数据库连接。我们可以执行任何需要从源数据库中选择数据并将其插入到目标数据库中的操作。在完成所有操作后，我们关闭连接。