渐进式构建Sequelize实例以访问和操作数据库

2023-12-31 07:43:03

Sequelize的操作方法

Sequelize通过提供多种方法，使开发人员能够轻松执行数据库操作。这些方法包括：

increment和decrement实例方法： 用于对模型实例中的数值字段进行递增或递减操作。
多个字段递增： 使用Sequelize的bulkUpdate方法，可以对多个字段进行同时递增或递减操作。
CRUD操作： Sequelize支持基本的CRUD操作，包括创建（create）、读取（read）、更新（update）和删除（delete）。

使用Sequelize进行数据库操作

创建模型实例

const { Sequelize, DataTypes } = require('sequelize');

const sequelize = new Sequelize('database', 'username', 'password', {
  host: 'localhost',
  dialect: 'mysql'
});

const User = sequelize.define('User', {
  id: {
    type: DataTypes.INTEGER,
    autoIncrement: true,
    primaryKey: true
  },
  name: {
    type: DataTypes.STRING,
    allowNull: false
  },
  email: {
    type: DataTypes.STRING,
    allowNull: false
  }
});

const user = await User.create({ name: 'John Doe', email: 'john.doe@example.com' });

数值的递增和递减

const { Sequelize, DataTypes } = require('sequelize');

const sequelize = new Sequelize('database', 'username', 'password', {
  host: 'localhost',
  dialect: 'mysql'
});

const User = sequelize.define('User', {
  id: {
    type: DataTypes.INTEGER,
    autoIncrement: true,
    primaryKey: true
  },
  name: {
    type: DataTypes.STRING,
    allowNull: false
  },
  email: {
    type: DataTypes.STRING,
    allowNull: false
  },
  age: {
    type: DataTypes.INTEGER,
    defaultValue: 0
  }
});

const user = await User.findByPk(1);
user.increment('age'); // 将user的age字段递增1
user.decrement('age', { by: 2 }); // 将user的age字段递减2

多个字段递增

const { Sequelize, DataTypes } = require('sequelize');

const sequelize = new Sequelize('database', 'username', 'password', {
  host: 'localhost',
  dialect: 'mysql'
});

const User = sequelize.define('User', {
  id: {
    type: DataTypes.INTEGER,
    autoIncrement: true,
    primaryKey: true
  },
  name: {
    type: DataTypes.STRING,
    allowNull: false
  },
  email: {
    type: DataTypes.STRING,
    allowNull: false
  },
  age: {
    type: DataTypes.INTEGER,
    defaultValue: 0
  },
  balance: {
    type: DataTypes.INTEGER,
    defaultValue: 0
  }
});

const users = await User.findAll();
await User.bulkUpdate(users, { increment: ['age', 'balance'] }); // 同时将所有用户的age和balance字段递增1

CRUD操作

const { Sequelize, DataTypes } = require('sequelize');

const sequelize = new Sequelize('database', 'username', 'password', {
  host: 'localhost',
  dialect: 'mysql'
});

const User = sequelize.define('User', {
  id: {
    type: DataTypes.INTEGER,
    autoIncrement: true,
    primaryKey: true
  },
  name: {
    type: DataTypes.STRING,
    allowNull: false
  },
  email: {
    type: DataTypes.STRING,
    allowNull: false
  }
});

// 创建
const user = await User.create({ name: 'John Doe', email: 'john.doe@example.com' });

// 读取
const users = await User.findAll();

// 更新
const user = await User.findByPk(1);
user.name = 'Jane Doe';
await user.save();

// 删除
const user = await User.findByPk(1);
await user.destroy();