tcp服务器与数据库连接

import socket
import mysql.connector

def handle_client(client_socket):
    try:
        # 建立数据库连接
        db = mysql.connector.connect(
            host="localhost",
            user="yourusername",
            password="yourpassword",
            database="yourdatabase"
        )
        cursor = db.cursor()

        # 接收客户端请求
        request = client_socket.recv(1024).decode()
        print(f"Received: {request}")

        # 执行SQL查询（假设请求是简单的SELECT语句）
        cursor.execute(request)
        result = cursor.fetchall()

        # 发送响应给客户端
        response = str(result)
        client_socket.send(response.encode())

    except Exception as e:
        print(f"Error: {e}")
    finally:
        cursor.close()
        db.close()
        client_socket.close()

def start_server():
    server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    server.bind(('0.0.0.0', 12345))
    server.listen(5)
    print("Server listening on port 12345")

    while True:
        client_sock, addr = server.accept()
        print(f"Accepted connection from {addr[0]}:{addr[1]}")
        handle_client(client_sock)

if __name__ == "__main__":
    start_server()