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

javascript怎么连接数据库

admin
数据库
2025-08-04
2

JavaScript中，通常通过Node.js搭配相应驱动（如mysql、pg等）来连接数据库，先安装依赖包，再编写代码建立连接。

是关于如何使用JavaScript连接数据库的详细介绍：

核心原理

由于浏览器端的JavaScript受安全限制无法直接访问数据库，因此实际开发中通常基于Node.js环境实现后端数据库交互，Node.js作为JavaScript的服务器端运行环境，可通过加载不同数据库驱动或ORM工具完成与MySQL、PostgreSQL、MongoDB等主流数据库的通信。

主流方案对比

类型	代表库/工具	适用场景	优势特点
原生驱动	`mysql2`, `pg`, `mongodb`	精细化控制SQL语句	高性能、低延迟；适合复杂事务处理
ORM框架	Sequelize, TypeORM	结构化项目开发	模型映射直观，自动生成迁移脚本；支持关联查询
ODM工具	Mongoose	NoSQL文档型数据库	简化Schema定义，内置数据校验功能
连接池管理	`mysql.createPool`	高并发场景	复用连接实例减少开销，提升吞吐量

具体实现步骤（以MySQL为例）

环境准备与依赖安装

npm install express mysql2 dotenv # Express用于构建API，mysql2为优化版驱动，dotenv管理环境变量

创建.env文件存储敏感信息：

DB_HOST=localhost
DB_USER=root
DB_PASS=your_password
DB_NAME=test_db

基础连接代码示例

const mysql = require('mysql2'); // 使用Promise支持的版本
const connection = mysql.createConnection({
  host: process.env.DB_HOST,      // 从环境变量读取配置
  user: process.env.DB_USER,
  password: process.env.DB_PASS,
  database: process.env.DB_NAME,
  waitForConnections: true         // 强制等待连接建立成功
});
// 异步错误处理模式
connection.connect(err => {
  if (err) throw new Error(`数据库连接失败: ${err.stack}`);
  console.log(`成功连接到ID为${connection.threadId}的数据库线程`);
});
// 执行查询并解析结果集
connection.execute('SELECT  FROM users WHERE age > ?', [18], (err, [rows]) => {
  if (err) return console.error('查询异常:', err);
  rows.forEach(user => console.log(`用户${user.id}: ${user.name}`));
});
// 推荐使用async/await语法糖
async function getActiveUsers() {
  const [results] = await connection.promise().query('SELECT  FROM users LIMIT 5');
  return results;
}

进阶优化策略

连接池配置（应对高并发）：

const pool = mysql.createPool({
  connectionLimit: 10,      // 同时保持的最大连接数
  queueLimit: 0,            // 允许等待中的请求无限增长（生产环境建议设为合理值）
  waitForConnections: true, // 确保始终有可用连接时才执行新请求
  ...process.env             // 合并环境变量中的其他参数
});

事务完整性保障：

const promiseConn = connection.promise();
await promiseConn.beginTransaction();
try {
  await promiseConn.query('UPDATE account SET balance -= ? WHERE id = ?', [amount, senderId]);
  await promiseConn.query('UPDATE account SET balance += ? WHERE id = ?', [amount, receiverId]);
  await promiseConn.commit();
} catch (e) {
  await promiseConn.rollback(); // 出错时回滚所有已执行操作
  throw e;
}

ORM框架实战（以Sequelize为例）

初始化及模型定义

const { Sequelize, DataTypes } = require('sequelize');
const sequelize = new Sequelize(process.env.DB_NAME, process.env.DB_USER, process.env.DB_PASS, {
  host: process.env.DB_HOST,
  dialect: 'mysql',           // 根据实际使用的数据库调整类型标识符
  logging: false              // 关闭默认的SQL日志输出
});
// 定义用户模型（自动对应users表）
const User = sequelize.define('User', {
  username: { type: DataTypes.STRING, unique: true },
  email: { type: DataTypes.STRING, validate: { isEmail: true } }, // 内置验证规则
  createdAt: { type: DataTypes.DATE, defaultValue: Sequelize.NOW }
});
// 同步数据库结构到最新模型状态
await sequelize.sync({ alter: true }); // alter选项会修改现有表而非重建

CRUD操作演示

// 创建新记录
const jane = await User.create({ username: 'janedoe', email: 'jane@example.com' });
// 组合条件查询
const engineers = await User.findAll({ where: { role: 'engineer' }, order: [['salary', 'DESC']] });
// 更新特定字段
await User.update({ status: 'active' }, { where: { lastLoginDate: { [Op.gt]: new Date().setDate(new Date().getDate() 30) } } });
// 物理删除+软删除双模式支持
await User.destroy({ where: { id: expiredUserId }, force: true }); // force参数强制硬删除

常见问题解决方案

症状	可能原因	修复方案
ECONNREFUSED错误	防火墙阻止端口通信	检查服务器防火墙设置，确认3306/27017等端口已开放给Node进程
Too many connections报错	未正确释放数据库连接	确保每次请求结束后调用connection.release()或使用连接池自动回收机制
中文字符显示乱码	编码格式不匹配	在连接配置中添加`charset: 'utf8mb4'`参数支持完整Unicode字符集
TIMEZONE偏移导致时间错误	时区设置不一致	统一使用UTC时间存储，前端展示时根据用户本地时区转换
SQL注入破绽风险	直接拼接用户输入参数	始终使用参数化查询（如占位符），避免使用`${variable}`形式的字符串插值