Node.js中数据库连接与管理

在Node.js中，有多种方法可以连接到数据库并进行管理。以下是一些常见的数据库和相应的Node.js库，以及如何使用它们进行数据库连接和管理。

1. MongoDB

使用mongoose库连接到MongoDB数据库。

安装mongoose：

npm install mongoose

连接到MongoDB：

const mongoose = require('mongoose');
mongoose.connect('mongodb://localhost:27017/myDatabase', {
  useNewUrlParser: true,
  useUnifiedTopology: true,
});

管理数据库（例如，创建、读取、更新、删除）：

const Schema = mongoose.Schema;

const UserSchema = new Schema({
  name: String,
  age: Number,
});

const User = mongoose.model('User', UserSchema);

// 创建
const newUser = new User({ name: 'John', age: 30 });
newUser.save();

// 读取
User.find({});

// 更新
User.findOneAndUpdate({ name: 'John' }, { age: 31 });

// 删除
User.findOneAndDelete({ name: 'John' });

2. MySQL

使用mysql库连接到MySQL数据库。

安装mysql：

npm install mysql

连接到MySQL：

const mysql = require('mysql');

const connection = mysql.createConnection({
  host: 'localhost',
  user: 'root',
  password: 'password',
  database: 'myDatabase',
});

connection.connect();

管理数据库：

// 创建
connection.query('CREATE TABLE IF NOT EXISTS users (id INT AUTO_INCREMENT PRIMARY KEY, name VARCHAR(255), age INT)');

// 读取
connection.query('SELECT * FROM users', (error, results) => {
  if (error) throw error;
  console.log(results);
});

// 更新
connection.query('UPDATE users SET age = 31 WHERE name = "John"');

// 删除
connection.query('DELETE FROM users WHERE name = "John"');

3. PostgreSQL

使用pg库连接到PostgreSQL数据库。

安装pg：

npm install pg

连接到PostgreSQL：

const { Pool } = require('pg');

const pool = new Pool({
  user: 'root',
  host: 'localhost',
  database: 'myDatabase',
  password: 'password',
  port: 5432,
});

管理数据库：

// 创建
pool.query('CREATE TABLE IF NOT EXISTS users (id SERIAL PRIMARY KEY, name VARCHAR(255), age INT)');

// 读取
pool.query('SELECT * FROM users', (error, results) => {
  if (error) throw error;
  console.log(results.rows);
});

// 更新
pool.query('UPDATE users SET age = 31 WHERE name = $1', ['John']);

// 删除
pool.query('DELETE FROM users WHERE name = $1', ['John']);

这些示例仅展示了如何连接到数据库并执行基本的CRUD操作。在实际应用中，您可能需要根据需求编写更复杂的查询和逻辑。同时，为了确保应用程序的安全性和稳定性，请务必处理错误和异常情况。