MySql简单的增删改查语句 js

最近在项目中须要链接数据库,作增删改查的功能,sql语句整理作了如下记录(基于NodeJs,注:data为你的真实数据):sql

(一)新增插入表中数据:数据库

sql: 'insert into work(表名) (name,id,src) values(?,?,?);',
values: [ //须要插入的对应属性
  data.name,
  data.id,
  data.src, ],

/******example******/

 insertWorkList = async (data) => {
  return new Promise((resolved, reject) => {
   connection.query({
    sql: 'insert into work(表名) (name,id,src) values(?,?,?);',
    values: [
     data.name,
     data.id,
     data.src,
    ],
   }, (error, results) => {
    if (error) {
     reject(error);
    } else {
     resolved(results);
    }
   });
  });
 };async

(二)更新表中数据(更新数据须要根据对应的惟一属性,例如id):spa

sql: 'update work(表名) set name=?, src=? where id=?',
values: [ //须要插入的对应属性
    data.name,
    data.src,
    data.id, //经过此id去更改name和src
],
/******example******/

 updateWorkById = async (data) => {
  return new Promise((resolved, reject) => {
   connection.query({
    sql: 'update work(表名) set name=?, src=? where id=?',
    values: [
     data.name,
     data.src,
     data.id,
    ],
   }, (error, results) => {
    if (error) {
     reject(error);
    } else {
     resolved(results);
    }
   });
  });
 };code

(三)查询表中的数据:blog

  (1)查询某个表单中全部的数据(注: 查询全部数据不用传输values值)  get

select * from work(表名)

 /******example******/io

 getList = async () => {
  return new Promise((resolved, reject) => {
   connection.query('select * from work', (error, results) => {
    if (error) {
     reject(error);
    } else {
     resolved(results);
    }
   });
  });
 };class

  (2)经过id或其余惟一属性查询某个表单中的数据表单

sql: 'select * from work where id=?',
values: [id],

/******example******/

getWorkById = async (id) => {
  return new Promise((resolved, reject) => {
   connection.query({
    sql: 'select * from work(表名) where id=?',
    values: [id],
   }, (error, results) => {
    if (error) {
     reject(error);
    } else {
     resolved(results);
    }
   });
  });
 };

(四)删除表中id或其余惟一属性对应的数据:

sql: 'delete from work where id=?',
values: [id],

/******example******/

deleteWorkById = async (id) => {
  return new Promise((resolved, reject) => {
   connection.query({
    sql: 'delete from work(表名) where id=?',
    values: [id],
   }, (error, results) => {
    if (error) {
     reject(error);
    } else {
     resolved(results);
    }
   });
  });
 };
相关文章
相关标签/搜索