### 使用Python进行数据库插入和查找操作 #### SQLite3 示例 对于SQLite3，可以通过`sqlite3`模块来实现数据的插入与查询功能。下面是一个完整的例子展示如何创建表、插入记录以及检索这些记录。 ```python import sqlite3 with sqlite3.connect(':memory:') as connection: # 使用内存中的临时数据库测试 cursor = connection.cursor() # 创建表格 create_table_query = """ CREATE TABLE IF NOT EXISTS employees ( id INTEGER PRIMARY KEY, name TEXT NOT NULL, position TEXT NOT NULL); """ cursor.execute(create_table_query) # 插入单条记录 insert_single_record_query = 'INSERT INTO employees (name, position) VALUES (?, ?)' employee_data = ('Alice', 'Manager') cursor.execute(insert_single_record_query, employee_data) # 插入多条记录 more_employees = [ ('Bob', 'Developer'), ('Charlie', 'Designer')] cursor.executemany(insert_single_record_query, more_employees) # 查询所有员工的信息 select_all_records_query = "SELECT * FROM employees" results = cursor.execute(select_all_records_query).fetchall() for result in results: print(f'ID {result[0]}: Name={result[1]}, Position={result[2]}') ``` 这段代码展示了怎样利用参数化查询防止SQL注入攻击[^3]，同时也体现了使用上下文管理器(`with`)简化资源管理和异常处理的方式[^4]。 #### PostgreSQL 示例 当涉及到更复杂的企业级应用场景时，可能会选择像PostgreSQL这样的关系型数据库管理系统。这里给出一段基于psycopg2库的操作实例： ```python import psycopg2 try: db_params = { 'host': 'localhost', 'port': '5432', 'user': 'your_username', 'password': '<PASSWORD>', 'dbname': 'test_db' } with psycopg2.connect(**db_params) as conn: cur = conn.cursor() # 建立新表并插入几条样本数据 setup_queries = [ """CREATE TABLE IF NOT EXISTS staff( emp_id SERIAL PRIMARY KEY, full_name VARCHAR(80), job_title VARCHAR(50))""", """INSERT INTO staff(full_name, job_title) VALUES (%s,%s),(%s,%s);""" ] sample_data = [('David Smith', 'Analyst'), ('Eva Brown', 'Consultant')] for query in setup_queries[:-1]: cur.execute(query) cur.executemany(setup_queries[-1], sample_data) # 获取全部职员列表 fetch_staff_list_query = "SELECT * FROM staff;" cur.execute(fetch_staff_list_query) fetched_rows = cur.fetchall() except Exception as error: print("An exception occurred:", str(error)) else: for row in fetched_rows or []: print(f'Staff ID:{row[0]}, Full Name:{row[1]}, Job Title:{row[2]}') finally: pass # 这里不需要显式关闭连接因为已经在with语句中完成了 ``` 上述脚本说明了通过指定主机名、端口号和其他必要的认证信息建立远程数据库会话的过程，并执行了一系列DDL（定义）和DML（操纵）命令完成相应的增删改查动作[^5]。