Skip to content

最小示例

js
const sqlite3 = require('sqlite3').verbose();

//新建并连接本地数据库
var db = new sqlite3.Database("db111.db", function(err) {
    if (err) throw err;
});

//创建表
creatTable = (name,list,callback) =>{
    db.run(`create table ${name} (${list})`,err=>{
        if(err) return err;
        callback();
    })
}


//串行模式
db.serialize(()=>{

    try {
        creatTable('user','id INT PRIMARY KEY NOT NULL,NAME TEXT NOT NULL,AGE INT NOT NULL',function(err){
            console.log('创建表成功');
        });
    } catch (error) {
        console.log('表已存在');
    }

    try {
        //插入单挑数据
        for(let i = 0;i< 10;i++){
            db.run(`insert into user values (${i},'admin+${i}',${i+15})`,err=>{
                if(err) return err;
                console.log("插入成功:"+i);
            })
        }
    } catch (error) {
        console.log("数据已经插入");
    }
    

    //查询现有所有数据
   db.each("select * from user",(err,row)=>{
       if(err) throw err;
       console.log(row);
       
   },(err,res)=>{
       console.log(`查到了${res}行数据`);
       
   })

})




//关闭数据库
db.close(err=>{
    if(err) throw err;
    console.log("关闭数据库");
});