Python 使用Python (pyodbc)从SQL Server存储过程中调用

在本文中，我们将介绍如何使用Python库pyodbc从SQL Server数据库中调用存储过程。Python是一种功能强大的编程语言，而pyodbc则是一个流行的库，用于连接和操作数据库。

什么是存储过程？

存储过程是一组预编译的SQL语句，被保存在数据库中以便重复使用。它们可以接受输入参数，进行一系列操作，并返回结果。存储过程常用于执行复杂的数据库操作，提高性能并减少重复代码。

连接到SQL Server数据库

首先，我们需要安装pyodbc库。可以使用pip命令在终端中进行安装：

pip install pyodbc

安装完成后，我们可以通过以下步骤连接到SQL Server数据库：

import pyodbc

# 设置数据库连接信息
server = 'localhost'
database = 'mydb'
username = 'sa'
password = 'password'

# 连接到数据库
cnxn = pyodbc.connect('DRIVER={SQL Server};SERVER='+server+';DATABASE='+database+';UID='+username+';PWD='+ password)

以上代码中，我们使用pyodbc.connect()函数连接到SQL Server数据库。需要提供正确的服务器地址、数据库名、用户名和密码。

调用存储过程

连接到数据库后，我们可以使用cursor()方法创建一个光标对象，并使用该光标对象来执行SQL语句。

下面是一个示例，展示了如何调用存储过程并获取结果：

# 创建光标对象
cursor = cnxn.cursor()

# 定义存储过程名称和参数
procedure_name = 'GetEmployeeDetails'
employee_id = 1

# 执行存储过程
cursor.execute("EXEC "+procedure_name+" @EmployeeID=?", employee_id)

# 获取结果
result = cursor.fetchall()

# 打印结果
for row in result:
    print(row)

在上述示例中，我们首先创建了一个cursor对象，然后定义存储过程的名称和参数。接下来，使用execute()方法执行带有参数的存储过程。最后，使用fetchall()方法获取结果集，并使用循环打印每一行的结果。

传递输入参数

要向存储过程传递输入参数，只需在execute()方法中使用问号(?)占位符，并在execute()方法的参数列表中提供实际的参数值。

以下是一个示例，展示了如何传递输入参数给存储过程：

# 创建光标对象
cursor = cnxn.cursor()

# 定义存储过程名称和参数
procedure_name = 'UpdateEmployeeSalary'
employee_id = 1
new_salary = 50000

# 执行存储过程
cursor.execute("EXEC "+procedure_name+" @EmployeeID=?, @NewSalary=?", employee_id, new_salary)

# 提交事务
cnxn.commit()

在上述示例中，我们定义了存储过程的名称和两个输入参数。使用?占位符在execute()方法中指定参数位置，并在execute()方法的参数列表中提供实际的参数值。

执行存储过程后，我们需要调用commit()方法提交事务，以确保对数据库的更改生效。

获取输出参数

存储过程可以返回输出参数。要获取输出参数的值，可以使用output()方法指定参数位置。

以下是一个示例，展示了如何获取存储过程的输出参数：

# 创建光标对象
cursor = cnxn.cursor()

# 定义存储过程名称和参数
procedure_name = 'GetEmployeeCount'
employee_count = 0

# 执行存储过程
cursor.execute("EXEC "+procedure_name+" @EmployeeCount=?", employee_count)

# 获取输出参数的值
employee_count = cursor.getoutputparams()[0].value

# 打印输出结果
print("Employee Count:", employee_count)

在上述示例中，我们定义了存储过程的名称和一个输出参数。使用?占位符在execute()方法中指定参数位置，并在execute()方法的参数列表中提供初始值。

执行存储过程后，我们可以使用getoutputparams()方法获取输出参数的值，并使用value属性获取其实际值。

错误处理

在执行存储过程时，可能会遇到错误情况。我们可以使用try...except块来捕获并处理错误。

以下是一个示例，展示了如何处理执行存储过程时的错误：

try:
    # 执行存储过程
    cursor.execute("EXEC "+procedure_name+" @EmployeeID=?", employee_id)
except pyodbc.Error as e:
    # 处理错误
    print("Error executing stored procedure:", e)

在上述示例中，我们使用try...except块来执行存储过程。如果在执行存储过程时发生错误，将被捕获并在except块中进行处理。