不要怂,就是干,撸起袖子干!

connection.ts 974 Bytes
import { QueryTypes, Sequelize, SyncOptions } from 'sequelize';
import { User } from 'models/User';

export const sequelize = new Sequelize('uri');

sequelize.afterBulkSync((options: SyncOptions) => {
  console.log('synced');
});

async function test() {
  const rows: unknown[] = await sequelize
  .query('SELECT * FROM `test`', {
    type: QueryTypes.SELECT,
  });
  const [autoIncrementId, affectedRows] = await sequelize
  .query('INSERT into test set test=1', {
    type: QueryTypes.INSERT,
  });
}




sequelize.transaction<void>(async transaction => {
  const rows = await sequelize
    .query('SELECT * FROM `user`', {
      retry: {
        max: 123,
      },
      model: User,
      transaction,
      logging: true,
    })
});

sequelize.query('SELECT * FROM `user` WHERE status = $1',
  { bind: ['active'], type: QueryTypes.SELECT }
);

sequelize.query('SELECT * FROM `user` WHERE status = $status',
  { bind: { status: 'active' }, type: QueryTypes.SELECT }
);