程序员文章、书籍推荐和程序员创业信息与资源分享平台

网站首页 > 技术文章 正文

Python 读写Sqlserver数据库

hfteth 2024-12-16 13:22:51 技术文章 33 ℃

要在Python中读写SQL Server数据库,您可以使用pyodbc库。

以下是一个示例代码,演示如何连接到SQL Server数据库并执行读写操作:

import pyodbc

# 连接到SQL Server数据库
def connect_to_sql_server():
    conn = pyodbc.connect(
        'Driver={SQL Server};'
        'Server=your_server_name;'
        'Database=your_database;'
        'UID=your_username;'
        'PWD=your_password;'
    )
    return conn

# 执行查询语句
def execute_query(conn, query):
    cursor = conn.cursor()
    cursor.execute(query)
    result = cursor.fetchall()
    cursor.close()
    return result

# 执行插入语句
def execute_insert(conn, query, values):
    cursor = conn.cursor()
    cursor.execute(query, values)
    conn.commit()
    cursor.close()

# 示例用法
conn = connect_to_sql_server()

# 执行查询
select_query = "SELECT * FROM your_table"
result = execute_query(conn, select_query)
for row in result:
    print(row)

# 执行插入
insert_query = "INSERT INTO your_table (column1, column2) VALUES (?, ?)"
insert_values = ("value1", "value2")
execute_insert(conn, insert_query, insert_values)

# 关闭数据库连接
conn.close()

在上面的示例中,我们首先定义了一个connect_to_sql_server函数,它使用pyodbc.connect方法连接到SQL Server数据库。您需要提供正确的服务器名称、数据库名称、用户名和密码。

然后,我们定义了一个execute_query函数,它接受一个连接对象和查询语句作为参数,并使用cursor.execute方法执行查询。我们使用cursor.fetchall方法获取查询结果,并在示例中打印每一行。

接下来,我们定义了一个execute_insert函数,它接受一个连接对象、插入语句和值作为参数,并使用cursor.execute方法执行插入操作。我们使用conn.commit方法提交事务,并在示例中插入了一行数据。

最后,我们连接到SQL Server数据库,执行查询和插入操作,并关闭数据库连接。

请确保将your_server_nameyour_databaseyour_usernameyour_passwordyour_table等替换为实际的数据库凭据和表名。确保您已经安装了pyodbc库,并且已经安装了适当的SQL Server驱动程序。

Tags:

最近发表
标签列表