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

以下是使用pymysql库在Python中切换数据库的代码示例：

import pymysql

# 建立连接
conn = pymysql.connect(host='localhost', user='root', password='123456', database='db1')

# 创建游标对象
cursor = conn.cursor()

# 切换数据库
cursor.execute('USE db2')

# 执行SQL语句
cursor.execute('SELECT * FROM table1')

# 获取查询结果
results = cursor.fetchall()

# 关闭游标和连接
cursor.close()
conn.close()

在上面的代码中，首先使用pymysql库建立与数据库的连接，并创建一个游标对象。然后，使用`USE`语句切换到另一个数据库，并执行SQL查询语句。最后，获取查询结果并关闭游标和连接。

相关问题

pymysql ETL项目定义一个类下面数据库工具开发中切换数据库的代码

以下是一个基于pymysql的数据库工具类，其中包含了切换数据库的方法：

import pymysql

class DatabaseTool:
    def __init__(self, host, port, user, password, database):
        self.conn = pymysql.connect(host=host, port=port, user=user, password=password, database=database)
        self.cursor = self.conn.cursor()

    def switch_database(self, database):
        self.conn.select_db(database)

    def execute_query(self, query):
        self.cursor.execute(query)
        result = self.cursor.fetchall()
        return result

    def execute_update(self, query):
        self.cursor.execute(query)
        self.conn.commit()

    def close_connection(self):
        self.cursor.close()
        self.conn.close()

在上述代码中，`switch_database`方法接受一个数据库名作为参数，然后使用`select_db`方法切换到对应的数据库。其他方法可以用来执行查询和更新操作，并且在使用完后需要调用`close_connection`方法关闭连接。

pymysql怎么连数据库

可以使用如下代码连接数据库：

import pymysql

conn = pymysql.connect(
host='localhost',
port=3306,
user='root',
password='password',
db='database_name'
)

cursor = conn.cursor()

# 进行数据库操作

cursor.close()
conn.close()