在Python中连接和操作MSSQL Server数据库，通常可以使用`pyodbc`库。`pyodbc`是一个开源的Python库，它允许Python程序通过ODBC接口与各种数据库进行交互，包括MSSQL Server。为了更好地管理和复用代码，通常会将数据库连接和操作的逻辑进行封装。 ### 使用 `pyodbc` 连接 MSSQL Server 首先，你需要安装`pyodbc`库，可以通过以下命令进行安装： ```bash pip install pyodbc ``` 接下来，可以使用以下代码来连接MSSQL Server数据库，并执行简单的查询操作： ```python import pyodbc # 定义数据库连接信息 server = 'your_server_name' database = 'your_database_name' username = 'your_username' password = 'your_password' # 建立数据库连接 conn = pyodbc.connect(f'DRIVER={{ODBC Driver 17 for SQL Server}};SERVER={server};DATABASE={database};UID={username};PWD={password}') # 创建游标对象 cursor = conn.cursor() # 执行SQL查询 cursor.execute("SELECT TOP 5 * FROM your_table_name") # 获取查询结果 rows = cursor.fetchall() for row in rows: print(row) # 关闭游标和连接 cursor.close() conn.close() ``` ### 封装数据库连接和操作 为了提高代码的可重用性和可维护性，可以将上述代码封装成一个类，以便于管理和调用： ```python import pyodbc class MSSQLDatabase: def __init__(self, server, database, username, password): self.server = server self.database = database self.username = username self.password = password self.conn = None self.cursor = None def connect(self): self.conn = pyodbc.connect(f'DRIVER={{ODBC Driver 17 for SQL Server}};SERVER={self.server};DATABASE={self.database};UID={self.username};PWD={self.password}') self.cursor = self.conn.cursor() def execute_query(self, query): if not self.conn: self.connect() self.cursor.execute(query) return self.cursor.fetchall() def execute_non_query(self, query): if not self.conn: self.connect() self.cursor.execute(query) self.conn.commit() def close(self): if self.cursor: self.cursor.close() if self.conn: self.conn.close() # 使用封装的类连接并操作数据库 db = MSSQLDatabase(server='your_server_name', database='your_database_name', username='your_username', password='your_password') db.connect() results = db.execute_query("SELECT TOP 5 * FROM your_table_name") for row in results: print(row) db.close() ``` 通过这种方式，你可以轻松地在Python中连接和操作MSSQL Server数据库，并且代码结构更加清晰，易于维护和扩展。 ###