在Python中连接和操作SQL Server数据库，通常使用`pymssql`库来实现。以下是一个完整的示例，展示了如何建立连接、执行查询、处理结果以及关闭连接。 ### 连接 SQL Server 数据库 使用 `pymssql.connect()` 方法建立与 SQL Server 的连接。需要提供服务器地址、用户名、密码和数据库名称等参数： ```python import pymssql # 建立数据库连接 conn = pymssql.connect( server='localhost', # 服务器地址 user='sa', # 用户名 password='your_password', # 密码 database='your_database' # 数据库名称 ) if conn: print("连接数据库成功！") ``` ### 执行 SQL 查询 通过游标对象 `cursor()` 来执行 SQL 查询并获取结果： ```python # 创建游标对象 cursor = conn.cursor() # 定义 SQL 查询语句 sql_query = "SELECT * FROM your_table" # 执行 SQL 查询 cursor.execute(sql_query) # 获取所有查询结果 results = cursor.fetchall() # 遍历并处理结果 for row in results: print(row) ``` ### 插入、更新和删除数据 对于写操作（如插入、更新和删除），需要在执行后调用 `commit()` 方法提交事务： ```python # 插入数据示例 insert_sql = "INSERT INTO your_table (column1, column2) VALUES (%s, %s)" cursor.execute(insert_sql, ('value1', 'value2')) conn.commit() print("数据插入成功！") # 更新数据示例 update_sql = "UPDATE your_table SET column1 = %s WHERE column2 = %s" cursor.execute(update_sql, ('new_value', 'condition_value')) conn.commit() print("数据更新成功！") # 删除数据示例 delete_sql = "DELETE FROM your_table WHERE column = %s" cursor.execute(delete_sql, ('value_to_delete',)) conn.commit() print("数据删除成功！") ``` ### 关闭连接 操作完成后，务必关闭游标和数据库连接以释放资源： ```python # 关闭游标 cursor.close() # 关闭数据库连接 conn.close() print("数据库连接已关闭。") ``` ### 注意事项 - 确保数据库服务正在运行，并且允许远程连接（如果连接的是远程数据库）。 - 使用 `fetchall()` 获取所有结果时，注意内存使用，避免处理超大数据集。 - 在处理字符串字段时，可以参考去除空格等操作以提高数据一致性[^3]。