Python3连接SQL Server


本文将详细介绍如何使用Python3连接SQL Server数据库,并提供相应的代码示例。

一、安装pyodbc库

要连接SQL Server数据库,首先需要安装pyodbc库。可以通过以下命令来安装:

pip install pyodbc

二、建立数据库连接

在开始使用pyodbc连接SQL Server之前,需要先建立数据库连接对象。可以使用以下代码示例:

import pyodbc

# 连接数据库
conn = pyodbc.connect('DRIVER={SQL Server};SERVER=服务器地址;DATABASE=数据库名;UID=用户名;PWD=密码')

说明:

  • DRIVER:指定数据库驱动,这里是SQL Server。
  • SERVER:指定服务器地址,可以是IP地址或者服务器名。
  • DATABASE:指定要连接的数据库名。
  • UID:指定用户名。
  • PWD:指定密码。

三、执行SQL查询语句

在建立数据库连接之后,可以通过执行SQL查询语句来获取数据。以下是一个简单的示例:

# 创建游标
cursor = conn.cursor()

# 执行SQL查询语句
cursor.execute('SELECT * FROM 表名')

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

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

# 关闭游标和数据库连接
cursor.close()
conn.close()

四、插入数据

如果需要向SQL Server数据库中插入数据,可以使用以下代码示例:

# 创建游标
cursor = conn.cursor()

# 插入数据
cursor.execute('INSERT INTO 表名(字段1, 字段2) VALUES (?, ?)', ('value1', 'value2'))

# 提交事务
conn.commit()

# 关闭游标和数据库连接
cursor.close()
conn.close()

说明:

  • INSERT INTO 表名(字段1, 字段2) VALUES (?, ?):要插入数据的SQL语句,字段名需要与数据库中的表对应。
  • ('value1', 'value2'):要插入的数据值,按照字段的顺序传入。
  • conn.commit():提交事务,将插入的数据真正写入数据库。

五、更新数据

要更新SQL Server数据库中的数据,可以使用以下代码示例:

# 创建游标
cursor = conn.cursor()

# 更新数据
cursor.execute('UPDATE 表名 SET 字段1 = ? WHERE 条件', ('new_value',))

# 提交事务
conn.commit()

# 关闭游标和数据库连接
cursor.close()
conn.close()

说明:

  • UPDATE 表名 SET 字段1 = ? WHERE 条件:要更新数据的SQL语句,可以根据条件将符合条件的数据进行更新。
  • ('new_value',):要更新的新值,按照字段的顺序传入。

六、删除数据

如果需要删除SQL Server数据库中的数据,可以使用以下代码示例:

# 创建游标
cursor = conn.cursor()

# 删除数据
cursor.execute('DELETE FROM 表名 WHERE 条件')

# 提交事务
conn.commit()

# 关闭游标和数据库连接
cursor.close()
conn.close()

说明:

  • DELETE FROM 表名 WHERE 条件:要删除数据的SQL语句,可以根据条件将符合条件的数据进行删除。

七、异常处理

在连接SQL Server数据库和执行数据库操作的过程中,可能会出现一些异常情况。为了保证程序的稳定性,可以使用try-except语句进行异常处理。以下是一个示例:

try:
    # 连接数据库
    conn = pyodbc.connect('DRIVER={SQL Server};SERVER=服务器地址;DATABASE=数据库名;UID=用户名;PWD=密码')

    # 执行SQL查询语句
    cursor = conn.cursor()
    cursor.execute('SELECT * FROM 表名')

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

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

    # 关闭游标和数据库连接
    cursor.close()
    conn.close()
except Exception as e:
    print('发生异常:', str(e))

八、总结

通过以上的介绍,我们可以看到使用Python3连接SQL Server数据库非常简单。只需要安装pyodbc库,建立数据库连接对象,然后执行SQL查询语句或者插入、更新、删除数据就可以了。同时,我们也介绍了异常处理的方法,以确保程序的稳定性。希望本文对你在使用Python3连接SQL Server时有所帮助!

注意:文章中的服务器地址、数据库名、用户名和密码需要根据实际情况进行替换。

评论关闭