如何使用 Python 和 MySQL 从客户端查询服务器端数据库？

使用 Python 和 MySQL 从客户端查询服务器端数据库

背景

在开发过程中，我们经常需要从客户端应用程序访问存储在服务器端数据库中的数据。Python 语言提供了强大的功能，结合 MySQL 等流行的数据库管理系统，我们可以轻松实现这一目标。本文将深入探讨使用 Python 的 socket 模块从客户端查询服务器端 MySQL 数据库的方法。

设置服务器

第一步，我们需要创建一个服务器脚本（以下称为 server_db.py），它将执行以下任务：

• 侦听来自客户端的连接请求
• 处理来自客户端的查询
• 将结果返回给客户端

服务器端代码如下：

# 导入必要的模块
import socket
import ast
import mysql.connector
from mysql.connector import errorcode

try:
    # 建立与数据库的连接
    conn = mysql.connector.connect(
        host='localhost',
        user='root',
        password='root',
        database='mmdb'
    )
    print("已连接到数据库...")
    cur = conn.cursor()
except mysql.errorcode as err:
    print(err)

# 设置服务器参数
host = 'localhost'
port = 50000

# 创建套接字并开始侦听
mySocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
mySocket.bind((host, port))
mySocket.listen()

# 循环等待客户端连接
while 1:
    # 接收客户端连接
    connexion, adresse = mySocket.accept()
    # 接收来自客户端的查询
    msgClient = connexion.recv(1024).decode('utf8')
    # 执行查询并获取结果
    cur.execute(msgClient)
    resultat = cur.fetchall()
    # 将结果转换为字符串并发送给客户端
    resultat_str = str(resultat)
    connexion.send(resultat_str.encode('utf8'))
    # 接收客户端确认信息
    msgClient = connexion.recv(1024).decode('utf8')
    # 关闭连接
    connexion.close()
    # 询问是否继续或退出
    ch = input("<R>ecommencer <T>erminer ? ")
    if ch.upper() == "T":
        break

# 关闭套接字
mySocket.close()

设置客户端

接下来，我们需要创建一个客户端脚本（以下称为 client_db.py），它将执行以下任务：

• 连接到服务器
• 发送查询
• 接收并显示结果

客户端端代码如下：

# 导入必要的模块
import socket, threading
import ast

# 设置服务器参数
host = 'localhost'
port = 50000

# 创建发送线程类
class ThreadEmission(threading.Thread):
    def __init__(self, conn):
        threading.Thread.__init__(self)
        self.connexion = conn

    def run(self):
        ident = 2
        pays='Guinée'
        # 构建查询并发送给服务器
        msgClient = f"SELECT * FROM ami WHERE fk_identreprise={ident} AND paysAmi='{pays}';"
        self.connexion.send(msgClient.encode('utf8'))
        self.connexion.close()

# 创建接收线程类
class ThreadReception(threading.Thread):
    def __init__(self, conn):
        threading.Thread.__init__(self)
        self.connexion = conn

    def run(self):
        # 接收服务器返回的结果
        msgServeur = self.connexion.recv(1024).decode('utf8')
        # 将结果转换为列表并打印
        resultat = ast.literal_eval(msgServeur)
        print(resultat)
        print(type(resultat))

# 创建套接字并连接到服务器
myClient = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
myClient.connect((host, port))

# 创建发送和接收线程
th_E = ThreadEmission(myClient)
th_R = ThreadReception(myClient)
# 启动线程
th_E.start()
th_R.start()

解决变量问题

在初始的客户端代码中，你可能会遇到一个错误，表明变量 pays 在服务器端不存在。这是因为你在查询中使用了未定义的变量 pays。为了解决此问题，我们需要将 pays 变量传递给 ThreadEmission 线程的构造函数。修改后的 ThreadEmission 线程类如下：

# 创建发送线程类
class ThreadEmission(threading.Thread):
    def __init__(self, conn, pays):
        threading.Thread.__init__(self)
        self.connexion = conn
        self.pays = pays

    def run(self):
        ident = 2
        # 构建查询并发送给服务器
        msgClient = f"SELECT * FROM ami WHERE fk_identreprise={ident} AND paysAmi='{self.pays}';"
        self.connexion.send(msgClient.encode('utf8'))
        self.connexion.close()

在 client_db.py 的最后，你需要创建 ThreadEmission 线程并传入 pays 变量：

# 创建发送线程
th_E = ThreadEmission(myClient, 'Guinée')

运行代码

现在，你可以运行 server_db.py 和 client_db.py 脚本，并且查询应该可以正常工作。确保在运行之前 MySQL 服务正在运行，并且你可以连接到数据库。

常见问题解答

1. 如何修改查询？

你可以直接修改服务器端脚本中的查询语句，然后重新运行脚本。

2. 如何连接到不同的数据库？

在 server_db.py 脚本中修改数据库连接信息，例如主机名、用户名、密码和数据库名称。

3. 如何处理连接错误？

你可以使用异常处理来捕获并处理连接错误。

4. 如何提高查询效率？

使用索引、优化查询语句并调整服务器配置可以提高查询效率。

5. 如何保护数据安全？

使用 SSL 加密连接，使用安全密码并限制对数据库的访问权限可以保护数据安全。

结论

利用 Python 的 socket 模块和 MySQL，你可以轻松地从客户端应用程序查询服务器端数据库。通过遵循本文中的步骤，你将能够设置服务器和客户端脚本，并有效地查询和获取数据。理解并解决变量问题是确保查询成功执行的关键。通过遵循最佳实践并解决潜在问题，你可以构建高效且安全的客户端-服务器通信应用程序。