python 数据导入mysql

import mysql.connector
from mysql.connector import Error

def create_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,
            database=db_name
        )
        print("Connection to MySQL DB successful")
    except Error as e:
        print(f"The error '{e}' occurred")

    return connection

def execute_query(connection, query):
    cursor = connection.cursor()
    try:
        cursor.execute(query)
        connection.commit()
        print("Query executed successfully")
    except Error as e:
        print(f"The error '{e}' occurred")

# 创建数据库连接
connection = create_connection("localhost", "root", "password", "test_db")

# 插入数据的 SQL 查询
sql_insert_query = """
INSERT INTO users (name, email) VALUES 
('John Doe', 'john@example.com'),
('Jane Doe', 'jane@example.com')
"""

# 执行 SQL 查询
execute_query(connection, sql_insert_query)

# 关闭数据库连接
if connection.is_connected():
    connection.close()
    print("MySQL connection is closed")