当前位置：首页 > 数据库 > 正文

如何用代码创建数据库连接？

admin
数据库
2025-06-15
7

使用代码添加数据库连接需导入数据库驱动库，调用连接函数并传入主机、端口、用户名、密码及数据库名等参数，以Python为例，常用 pymysql.connect()或 sqlite3.connect()建立连接，最后需显式关闭连接释放资源。

核心准备工作

获取数据库凭据
- 数据库类型（MySQL/PostgreSQL/SQL Server等）
- 主机地址（如 localhost 或云数据库IP）
- 端口号（MySQL默认3306，PostgreSQL默认5432）
- 数据库名称
- 用户名和密码
安装数据库驱动
根据语言选择对应驱动：
# Python pip install mysql-connector-python pymysql # Node.js npm install mysql2 # Java (Maven) <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <version>8.0.33</version> </dependency>

代码实现示例

Python (MySQL)

import mysql.connector from mysql.connector import Error try: # 创建连接 connection = mysql.connector.connect( host="localhost", user="your_username", password="your_password", database="your_database" ) if connection.is_connected(): cursor = connection.cursor() cursor.execute("SELECT VERSION()") # 测试查询 version = cursor.fetchone() print("Database version:", version) except Error as e: print("连接失败:", e) finally: if connection.is_connected(): cursor.close() connection.close() # 必须关闭连接！

Node.js (MySQL)

const mysql = require('mysql2'); // 创建连接池（推荐） const pool = mysql.createPool({ host: 'localhost', user: 'your_username', password: 'your_password', database: 'your_database', waitForConnections: true, connectionLimit: 10 }); // 执行查询 pool.query('SELECT 1 + 1 AS solution', (error, results) => { if (error) throw error; console.log('Result:', results[0].solution); }); // 关闭连接池（在应用退出时） process.on('exit', () => pool.end());

Java (JDBC)

import java.sql.*; public class DBConnection { public static void main(String[] args) { String url = "jdbc:mysql://localhost:3306/your_database"; String user = "your_username"; String password = "your_password"; try (Connection conn = DriverManager.getConnection(url, user, password); Statement stmt = conn.createStatement()) { ResultSet rs = stmt.executeQuery("SELECT VERSION()"); if (rs.next()) { System.out.println("Database version: " + rs.getString(1)); } } catch (SQLException e) { e.printStackTrace(); } } }

关键安全实践

绝不硬编码凭据
使用环境变量或配置文件：

# Python示例：从.env文件加载 from dotenv import load_dotenv import os load_dotenv() host = os.getenv("DB_HOST")
防御SQL载入
使用参数化查询（非字符串拼接）：

# Python安全查询 cursor.execute("SELECT * FROM users WHERE email = %s", (user_email,))
连接池管理
- 避免频繁创建/销毁连接（如Java的HikariCP、Python的DBUtils）
- 设置合理的连接超时时间
启用SSL加密
云数据库需配置SSL（以Node.js为例）：
const pool = mysql.createPool({ ssl: { rejectUnauthorized: true }, // ...其他配置 });

常见错误排查

错误现象	可能原因	解决方案
Connection refused	数据库服务未启动/端口错误	检查服务状态及防火墙设置
Access denied	用户名/密码错误	核对凭据及数据库权限
Too many connections	连接未关闭或超出限制	优化连接池配置，确保资源释放
SSL connection error	证书配置问题	更新CA证书或禁用SSL（仅测试）