python sqlserver

import pyodbc

# 连接到 SQL Server 数据库
def connect_to_sql_server(server, database, username, password):
    connection_string = f'DRIVER={{ODBC Driver 17 for SQL Server}};SERVER={server};DATABASE={database};UID={username};PWD={password}'
    try:
        conn = pyodbc.connect(connection_string)
        print("连接成功")
        return conn
    except pyodbc.Error as ex:
        print(f"连接失败: {ex}")
        return None

# 查询数据示例
def query_data(conn, query):
    try:
        cursor = conn.cursor()
        cursor.execute(query)
        rows = cursor.fetchall()
        for row in rows:
            print(row)
    except pyodbc.Error as ex:
        print(f"查询失败: {ex}")

# 插入数据示例
def insert_data(conn, insert_query, params):
    try:
        cursor = conn.cursor()
        cursor.execute(insert_query, params)
        conn.commit()
        print("插入成功")
    except pyodbc.Error as ex:
        print(f"插入失败: {ex}")

# 示例使用
if __name__ == "__main__":
    server = 'your_server_name'
    database = 'your_database_name'
    username = 'your_username'
    password = 'your_password'

    conn = connect_to_sql_server(server, database, username, password)

    if conn:
        # 查询示例
        query = "SELECT * FROM your_table"
        query_data(conn, query)

        # 插入示例
        insert_query = "INSERT INTO your_table (column1, column2) VALUES (?, ?)"
        params = ('value1', 'value2')
        insert_data(conn, insert_query, params)

        # 关闭连接
        conn.close()

解释说明：

1. 连接到 SQL Server 数据库：

   • 使用 pyodbc 库连接到 SQL Server 数据库。
   • connect_to_sql_server 函数接收服务器名、数据库名、用户名和密码作为参数，并返回一个数据库连接对象。

2. 查询数据：

   • query_data 函数接收数据库连接对象和 SQL 查询语句作为参数，执行查询并打印结果。

3. 插入数据：

   • insert_data 函数接收数据库连接对象、插入语句和参数列表作为参数，执行插入操作并将更改提交到数据库。

4. 示例使用：

   • 在 __main__ 块中，定义了服务器、数据库、用户名和密码，调用 connect_to_sql_server 函数建立连接，然后进行查询和插入操作，最后关闭连接。