数据库安全怎么做

import mysql.connector
from mysql.connector import Error

def create_connection():
    try:
        connection = mysql.connector.connect(
            host='localhost',
            database='mydatabase',
            user='myuser',
            password='mypassword'
        )
        if connection.is_connected():
            print("Connected to MySQL database")
        return connection
    except Error as e:
        print(f"Error: '{e}'")
        return None

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

# 创建连接
connection = create_connection()

# 执行查询
query = "CREATE TABLE IF NOT EXISTS users (id INT AUTO_INCREMENT PRIMARY KEY, name VARCHAR(255), email VARCHAR(255))"
execute_query(connection, query)

# 关闭连接
if connection.is_connected():
    cursor = connection.cursor()
    cursor.close()
    connection.close()
    print("MySQL connection is closed")