阅读量:0
import mysql.connector from mysql.connector import Error def create_database_connection(host_name, user_name, user_password, db_name): connection = None try: connection = mysql.connector.connect( host=host_name, user=user_name, passwd=user_password ) print("MySQL Database connection successful") except Error as e: print(f"The error '{e}' occurred") return connection def create_database(connection, query): cursor = connection.cursor() try: cursor.execute(query) print("Database created successfully") except Error as e: print(f"The error '{e}' occurred") 示例用法 if __name__ == "__main__": # 数据库连接信息 host_name = "your_host_name" user_name = "your_username" user_password = "your_password" db_name = "your_database_name" # 创建数据库连接 connection = create_database_connection(host_name, user_name, user_password, db_name) # 创建数据库的SQL语句 create_db_query = f"CREATE DATABASE IF NOT EXISTS {db_name}" # 创建数据库 if connection: create_database(connection, create_db_query) connection.close()
在上述代码中,首先导入了mysql.connector
模块,该模块用于连接MySQL数据库,然后定义了两个函数:
1、create_database_connection
:用于建立到MySQL数据库的连接。
2、create_database
:用于执行创建数据库的SQL语句。
示例用法部分展示了如何使用这两个函数来连接到MySQL数据库并创建一个新数据库,请确保替换your_host_name
、your_username
、your_password
和your_database_name
为实际的数据库连接信息。