在Python中,可以使用多種庫來連接數據庫并執行批量操作。以下是一些常用的庫和方法:
executemany()
方法可以執行批量插入操作。import sqlite3
# 連接數據庫
conn = sqlite3.connect('example.db')
cursor = conn.cursor()
# 創建表
cursor.execute('''CREATE TABLE IF NOT EXISTS users (id INTEGER PRIMARY KEY, name TEXT, age INTEGER)''')
# 批量插入數據
data = [
('Alice', 30),
('Bob', 25),
('Charlie', 22)
]
cursor.executemany('INSERT INTO users (name, age) VALUES (?, ?)', data)
# 提交事務
conn.commit()
# 查詢數據
cursor.execute('SELECT * FROM users')
print(cursor.fetchall())
# 關閉連接
conn.close()
executemany()
方法執行批量插入操作。import mysql.connector
# 連接數據庫
conn = mysql.connector.connect(
host='localhost',
user='your_username',
password='your_password',
database='example_db'
)
cursor = conn.cursor()
# 創建表
cursor.execute('''CREATE TABLE IF NOT EXISTS users (id INT AUTO_INCREMENT PRIMARY KEY, name VARCHAR(255), age INT)''')
# 批量插入數據
data = [
('Alice', 30),
('Bob', 25),
('Charlie', 22)
]
cursor.executemany('INSERT INTO users (name, age) VALUES (%s, %s)', data)
# 提交事務
conn.commit()
# 查詢數據
cursor.execute('SELECT * FROM users')
print(cursor.fetchall())
# 關閉連接
cursor.close()
conn.close()
executemany()
方法執行批量插入操作。from sqlalchemy import create_engine, Table, Column, Integer, String
from sqlalchemy.orm import sessionmaker
# 創建數據庫引擎
engine = create_engine('sqlite:///example.db')
# 定義表結構
metadata = MetaData()
users = Table('users', metadata,
Column('id', Integer, primary_key=True),
Column('name', String),
Column('age', Integer)
)
# 創建表
metadata.create_all(engine)
# 創建會話
Session = sessionmaker(bind=engine)
session = Session()
# 批量插入數據
data = [
('Alice', 30),
('Bob', 25),
('Charlie', 22)
]
session.execute(users.insert().values(data))
# 提交事務
session.commit()
# 查詢數據
result = session.query(users).all()
print(result)
# 關閉連接
session.close()
這些示例展示了如何使用不同的庫在Python中執行批量數據庫操作。根據你的需求和使用的數據庫類型,可以選擇合適的庫和方法。