最小示例
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("关闭数据库");
});