koa連線mysql資料庫並進行簡單增刪改查

2021-10-19 22:33:39 字數 3024 閱讀 8069

初級菜鳥,為圖方便暫時在路由中配置資料庫未使用連線池 ,路由檔案

const mysql = require(

'mysql'

) //引入資料庫外掛程式

const koarouter = require(

'koa-router');

const router = koarouter();

//連線資料庫

const connection = mysql.createconnection(

)//新增資料

router.post(

'/add', async (ctx, next)

=>

var createdtime=new date(

) var querysql=

"insert into address (createdtime,name,address,phone,belongsid) values(?,?,?,?,?)"

var queryparams=

[createdtime,ctx.request.query.name,ctx.request.query.address,ctx.request.query.phone,ctx.request.query.userid]

console.log(queryparams)

var searchsql =

(querysql,queryparams)

=>

resolve(result)})

})} var res= await searchsql(querysql,queryparams)

if(res)

else}}

);//查詢資料

router.get(

'/query', async (ctx, next)

=>

console.log(ctx.request.query.pageno - 1)

var querysql=

"select * from address where belongsid= '"+ctx.request.query.userid+"' limit "+ (ctx.request.query.pageno-1)*ctx.request.query.pagesize+"," + ctx.request.query.pagesize

var querysqlno=

"select * from address where belongsid= '"+ctx.request.query.userid+"'"

var searchsql =

(thesql)

=>

resolve(result)})

})} var res= await searchsql(querysqlno)

if(res)

data.code=

'0' data.msg=

"成功獲取"

data.data=param

ctx.body=data

}}})

//更新資料

router.post(

'/update', async (ctx, next)

=>

resolve(0)})

})} var data=

var res= await searchsql(updatesql)

if(res==0)

else})

;//刪除資料

router.post(

'/remove', async (ctx, next)

=>

resolve(0)})

})} var data=

var res= await searchsql(deletesql)

if(res==0)

else})

;

精華部分

拼接sql操作語句

執行sql操作語句

處理結果

增刪改查sql語句

增 :insert into address (createdtime,name,address,phone,belongsid) values(?,?,?,?,?)

var queryparams=[createdtime,ctx.request.query.name,ctx.request.query.address,ctx.request.query.phone,ctx.request.query.userid]

address 為查詢表名稱 queryparams為插入的新資料對應上面?的個數 也可直接講問號替換為對應的值

刪:「delete from address where 「+「id=『11111』』」 id=『11111』 為刪除符合的條件

address 為查詢表名稱 where 為滿足刪除的條件

改:「update address set name = '」+ctx.request.query.name+」』, phone = 『" + ctx.request.query.phone + "』, address = 『" + ctx.request.query.address +"』 where id = 『" +ctx.request.query.id + "』"

address 為查詢表名稱 set 和where之間為插入資料 where後為插入資料的id

查:select * from address where belongsid= 『"+ctx.request.query.userid+"』 limit 「+ (ctx.request.query.pageno-1)*ctx.request.query.pagesize+」," + ctx.request.query.pagesize

pageno為查詢頁碼 pagesize為查詢條數 belongsid=「」 為查詢條件 address 為查詢表名稱

var searchsql =

(thesql)

=>

resolve(0) //返回狀態 //只有查詢有具體返回內容

})})}

C 連線MYSQL資料庫並進行查詢

using mysql.data mysqlclient using system.data sqlclient 4 這裡進行簡單的頁面布局,用了乙個按鈕,乙個listview控制項,乙個datagridview控制項,其中listview控制項名字為listview1,datagridview控制...

C 連線MYSQL資料庫並進行查詢

摘要 之前用mfc開發結果介面太難看被pass了,要求用c 重新來開發 using system.data.sqlclient 4 這裡進行簡單的頁面布局,用了乙個按鈕,乙個listview控制項,乙個datagridview控制項,其中listview控制項名字為listview1,datagri...

Koa封裝MySQL資料庫

以下提供乙個node.js封裝的mysql資料庫的方法,歡迎各位碼農複製貼上!首先是封裝的資料庫檔案config.js var mysql require mysql 建立鏈結 function connection connection.connect return connection expo...