数据库设备管理系统源码

import mysql.connector

def connect_to_database(host, user, password, database):
    try:
        conn = mysql.connector.connect(
            host=host,
            user=user,
            password=password,
            database=database
        )
        return conn
    except mysql.connector.Error as err:
        print(f"Error: {err}")
        return None

def execute_query(conn, query):
    cursor = conn.cursor()
    try:
        cursor.execute(query)
        result = cursor.fetchall()
        return result
    except mysql.connector.Error as err:
        print(f"Error: {err}")
        return None

# 示例使用
host = "localhost"
user = "root"
password = "password"
database = "testdb"

conn = connect_to_database(host, user, password, database)
if conn:
    query = "SELECT * FROM devices"
    result = execute_query(conn, query)
    if result:
        for row in result:
            print(row)
    conn.close()