实现数据库建连、执行SQL并返回结果，核心就是选择正确的数据库驱动，建立连接后通过游标执行SQL语句，再调用fetch方法获取结果集，最后及时关闭连接。
数据库建连失败怎么办？常见原因和排查方法
执行SQL之前,连接失败是开发者最常遇到的阻碍，很多新手卡在这一步，不知道问题出在哪，业内专家指出，排查连接失败应从网络层开始，逐步深入。
为什么数据库建连会失败？
常见原因集中在以下四个方面：
- 网络连通性问题：数据库服务器IP地址或端口写错，服务器防火墙阻止了连接，或者客户端与服务器之间的网络不通，可以用
ping和telnet快速测试。 - 认证信息错误：用户名、密码或数据库名大小写敏感，尤其是MySQL默认大小写敏感，输入时容易忽略，用户权限不足也会导致连接被拒。
- 驱动版本不匹配：使用了过时的数据库驱动，或者驱动与数据库版本不兼容，MySQL 8.0以上需要较新的
mysql-connector或pymysql版本。 - 连接数超限：数据库的最大连接数限制，当活跃连接数达到上限时，新连接请求会被拒绝，此时需要调整
max_connections参数或使用连接池。
如何一步步排查？
按照以下路径,可以快速定位问题：
- 使用命令行工具尝试连接,
mysql -h host -u user -p，确认能否成功，如果命令行失败，问题出在数据库侧或网络侧。 - 检查网络连通性：
ping服务器IP，telnet端口，如果不通，联系网络管理员或检查防火墙规则。 - 验证驱动正确性：确认程序中引入的驱动库与数据库类型匹配，并且版本支持。
- 查看数据库错误日志,大部分数据库会记录连接失败的具体原因，这是最直接的线索。
Python连接MySQL执行SQL操作：从连接到返回结果
Python是数据处理的常用语言,连接MySQL执行SQL是常见场景，下面以 pymysql 为例，演示从建立连接到返回结果的完整流程。
准备工作
首先安装驱动：pip install pymysql，如果你使用其他数据库，如PostgreSQL，则用 psycopg2，但核心逻辑一致。
建立连接并设置超时
import pymysql
conn = pymysql.connect(
host='localhost',
user='root',
password='your_password',
database='your_db',
charset='utf8mb4',
connect_timeout=10 # 10秒超时
)
连接参数包括主机地址、端口（默认3306）、用户名、密码、数据库名，字符集建议使用 utf8mb4，支持完整Unicode，设置 connect_timeout 可以避免网络异常时程序长时间挂起。
创建游标并执行SQL
连接建立后,需要创建一个游标对象，用于执行SQL语句和获取结果。
cursor = conn.cursor() sql = "SELECT id, name, email FROM users WHERE status = 1" cursor.execute(sql)
获取返回结果
execute 执行后，结果保存在游标中，通过以下方法获取：
fetchone()：获取单行结果，返回元组或None。fetchall()：获取所有行，返回元组列表。fetchmany(size)：获取指定行数。
rows = cursor.fetchall()
for row in rows:
print(row[0], row[1], row[2])
使用DictCursor获取字典结果
默认游标返回元组,字段顺序需与SELECT一致，如果使用 DictCursor，结果会以字典形式返回，字段名作为键，代码更清晰。
cursor = conn.cursor(pymysql.cursors.DictCursor)
cursor.execute("SELECT id, name, email FROM users")
row = cursor.fetchone()
print(row['name']) # 直接通过字段名访问
处理事务
对于INSERT、UPDATE、DELETE等修改操作，需要显式提交事务，否则数据不会被持久化，使用 conn.commit() 提交，或 conn.rollback() 回滚。
清理资源
操作完成后,务必关闭游标和连接，释放数据库资源，推荐使用 try-finally 或 with 语句确保资源释放。
finally:
cursor.close()
conn.close()
连接池的引入
频繁建立和关闭连接开销较大,对于高并发场景，建议使用连接池，如 DBUtils 的 PooledDB，连接池维护一组活跃连接，复用它们，避免重复建连，据统计，多数Web应用引入连接池后性能提升明显。
数据库连接池与直连对比：哪种更适合你的场景？
连接池与直连是两种不同的连接管理方式,各有优劣，下面通过对比表格明确差异。
| 特性 | 直连（每次新建连接） | 连接池（复用连接） |
|---|---|---|
| 建立连接开销 | 每次请求都新建TCP连接，耗时较长 | 从池中获取已有连接，减少握手时间 |
| 并发处理能力 | 受限于数据库最大连接数，容易超限 | 池化管理，控制并发连接数，避免资源耗尽 |
| 资源占用 | 连接未及时关闭可能造成泄漏 | 空闲连接定时回收，资源利用率高 |
| 适用场景 | 低频率、短任务脚本 | 高并发、长运行的应用程序 |
连接池的关键参数
合理配置连接池参数,才能发挥最大效果，通常需要关注以下参数：
- 最小连接数：池中保持的最小存活连接数，确保系统随时可用。
- 最大连接数：池中允许的最大连接数，保护数据库不被过载。
- 空闲超时：连接空闲超过指定时间后，被回收释放。
- 连接最大存活时间：连接使用超过一定时间后强制关闭，防止连接泄漏。
如何选择？
- 如果你的应用是简单的定时脚本、数据分析任务，对性能要求不高，直连就足够了。
- 如果你在开发一个Web服务、API接口，需要频繁访问数据库，连接池是更优选择，行业共识认为，连接池的大小需要根据实际负载调整，一般从10-20开始，通过压力测试找到最优值。
数据库建连与执行SQL常见问题Q&A
问题1：数据库建连时出现”Access denied for user”怎么办？
检查用户名和密码是否正确,确认该用户是否允许从当前主机连接，MySQL中，用户权限与host绑定，'user'@'localhost' 只允许本地连接，使用 GRANT ALL ON db. TO 'user'@'%' 授权，或指定正确的host。
问题2：执行SQL后如何获取影响行数？
对于INSERT、UPDATE、DELETE，通过游标的 rowcount 属性获取受影响的行数。cursor.rowcount，对于SELECT，行数可以通过 len(cursor.fetchall()) 获得，但注意这会消耗结果集，建议在需要时使用。
问题3：连接池大小如何设置才合理？
连接池大小没有固定公式,取决于数据库实例的并发上限、业务流量和服务器资源，常见做法是从10-20开始，再通过压力测试调整，业界共识是，连接数并非越多越好，过多会增加数据库上下文切换开销，建议监控数据库连接数和响应时间，找到平衡点。
数据库建连、执行SQL并返回结果，是应用与数据交互的基础，掌握好连接管理、执行和结果处理，能让你在开发中少踩很多坑。
首发原创文章，作者：王坚，如若转载，请注明出处：https://idctop.com/%e5%a6%82%e4%bd%95%e5%bb%ba%e6%95%b0%e6%8d%ae%e5%ba%93%e5%b9%b6%e6%89%a7%e8%a1%8csql%e8%bf%94%e5%9b%9e%e7%bb%93%e6%9e%9c%ef%bc%8c%e6%95%b0%e6%8d%ae%e5%ba%93%e8%bf%9e%e6%8e%a5%e6%ad%a5%e9%aa%a4/
