node对数据库的增删改查

Node.js可以通过许多模块和库与数据库进行增删改查操作。以下是几个常用的模块和示例代码：

1. 使用MySQL数据库示例：

const mysql = require('mysql');

// 创建数据库连接
const connection = mysql.createConnection({
  host: 'localhost',
  user: 'root',
  password: 'password',
  database: 'mydatabase'
});

// 连接数据库
connection.connect((err) => {
  if (err) {
    console.error('数据库连接失败: ', err);
    return;
  }
  console.log('成功连接到数据库');
});

// 插入数据
const insertData = (data) => {
  const query = 'INSERT INTO table_name SET ?';
  connection.query(query, data, (err, result) => {
    if (err) {
      console.error('数据插入失败: ', err);
      return;
    }
    console.log('成功插入数据');
  });
};

// 查询数据
const selectData = () => {
  const query = 'SELECT * FROM table_name';
  connection.query(query, (err, result) => {
    if (err) {
      console.error('数据查询失败: ', err);
      return;
    }
    console.log('查询结果: ', result);
  });
};

// 更新数据
const updateData = (id, newData) => {
  const query = 'UPDATE table_name SET ? WHERE id = ?';
  connection.query(query, [newData, id], (err, result) => {
    if (err) {
      console.error('数据更新失败: ', err);
      return;
    }
    console.log('成功更新数据');
  });
};

// 删除数据
const deleteData = (id) => {
  const query = 'DELETE FROM table_name WHERE id = ?';
  connection.query(query, id, (err, result) => {
    if (err) {
      console.error('数据删除失败: ', err);
      return;
    }
    console.log('成功删除数据');
  });
};

// 断开数据库连接
connection.end();

2. 使用MongoDB数据库示例：

const mongodb = require('mongodb');
const MongoClient = mongodb.MongoClient;

// 连接MongoDB数据库
const url = 'mongodb://localhost:27017';
const dbName = 'mydatabase';

MongoClient.connect(url, (err, client) => {
  if (err) {
    console.error('数据库连接失败: ', err);
    return;
  }

  console.log('成功连接到数据库');

  const db = client.db(dbName);

  // 插入数据
  const insertData = (data, collectionName) => {
    const collection = db.collection(collectionName);
    collection.insertOne(data, (err, result) => {
      if (err) {
        console.error('数据插入失败: ', err);
        return;
      }
      console.log('成功插入数据');
    });
  };

  // 查询数据
  const selectData = (collectionName) => {
    const collection = db.collection(collectionName);
    collection.find({}).toArray((err, result) => {
      if (err) {
        console.error('数据查询失败: ', err);
        return;
      }
      console.log('查询结果: ', result);
    });
  };

  // 更新数据
  const updateData = (id, newData, collectionName) => {
    const collection = db.collection(collectionName);
    collection.updateOne({ _id: mongodb.ObjectID(id) }, { $set: newData }, (err, result) => {
      if (err) {
        console.error('数据更新失败: ', err);
        return;
      }
      console.log('成功更新数据');
    });
  };

  // 删除数据
  const deleteData = (id, collectionName) => {
    const collection = db.collection(collectionName);
    collection.deleteOne({ _id: mongodb.ObjectID(id) }, (err, result) => {
      if (err) {
        console.error('数据删除失败: ', err);
        return;
      }
      console.log('成功删除数据');
    });
  };

  // 关闭数据库连接
  client.close();
});

这些示例代码演示了如何使用Node.js连接MySQL和MongoDB数据库，并执行常见的增删改查操作。你可以根据自己的数据库类型和需求进行相应的调整和扩展。