#控制数据库import mysql.connectorfrom mysql.connector import Errordef connect(): try: conn = mysql.connector.connect( host='localhost', database='jsh_erp', user='root', password='root@12345678' ) if conn.is_connected(): print("Connected to MySQL database") return conn except Error as e: print(f"Error: {e}") return Nonedef query_data(connect,query): cursor = connect.cursor(dictionary=True) cursor.execute(query) result = cursor.fetchall() for row in result: print(row) cursor.close()if __name__ == '__main__': connect = connect() if connect: sql = 'select * from jsh_account' query_data(connect,sql) connect.close() print("数据库连接已关闭")
