服务器连接数据库通信代码

import mysql.connector

# 连接数据库
def connect_to_database():
    try:
        connection = mysql.connector.connect(
            host="数据库主机地址",
            user="数据库用户名",
            password="数据库密码",
            database="数据库名称"
        )
        return connection
    except mysql.connector.Error as error:
        print("连接数据库失败：{}".format(error))
        return None

# 查询数据
def execute_query(query):
    connection = connect_to_database()
    if connection is not None:
        try:
            cursor = connection.cursor()
            cursor.execute(query)
            result = cursor.fetchall()
            return result
        except mysql.connector.Error as error:
            print("执行查询失败：{}".format(error))
        finally:
            if connection.is_connected():
                cursor.close()
                connection.close()
    else:
        return None

# 插入数据
def execute_insert(query, values):
    connection = connect_to_database()
    if connection is not None:
        try:
            cursor = connection.cursor()
            cursor.execute(query, values)
            connection.commit()
            print("插入数据成功")
        except mysql.connector.Error as error:
            print("执行插入失败：{}".format(error))
        finally:
            if connection.is_connected():
                cursor.close()
                connection.close()
    else:
        return None

# 更新数据
def execute_update(query, values):
    connection = connect_to_database()
    if connection is not None:
        try:
            cursor = connection.cursor()
            cursor.execute(query, values)
            connection.commit()
            print("更新数据成功")
        except mysql.connector.Error as error:
            print("执行更新失败：{}".format(error))
        finally:
            if connection.is_connected():
                cursor.close()
                connection.close()
    else:
        return None

# 删除数据
def execute_delete(query):
    connection = connect_to_database()
    if connection is not None:
        try:
            cursor = connection.cursor()
            cursor.execute(query)
            connection.commit()
            print("删除数据成功")
        except mysql.connector.Error as error:
            print("执行删除失败：{}".format(error))
        finally:
            if connection.is_connected():
                cursor.close()
                connection.close()
    else:
        return None