接上一次的查詢操作,這次將更新與插入的代碼補充

首先是服務端的接收端,接收到客戶端的請求則發送相應操作

if ("1".equals(message)) {

//從mysql數據庫倉庫中查詢數據

jc.mysqlSelect("select * from cangku");

從oracle數據庫訂單表中查詢數據

//jc.oracleSelect("select * from freshbin_dingdan");

//當oracle數據中連接不上時候,就從本地的mysql數據庫的訂單表獲取數據

jc.mysqlSelectDingDan("select * from dingdan");

//獲取訂單表與倉庫表比較后,數量不同的結果

jc.writeIO();

//將兩張表比較后的結果返回給客戶端

os.write(jc.writeIO().toString().getBytes());

os.flush();

}

//這是更新操作的功能代碼

if("2".equals(message)) {

UpdateMySqlCangKuNumber umsck = new UpdateMySqlCangKuNumber();

//將需要更新以及插入的數據發送給客戶端

StringBuffer sb = umsck.getUpdateInsertNumber();

os.write(sb.toString().getBytes());

}

os.write(("請輸入1或2(1為查詢,2為更新):\n").getBytes());

}

然后是獲取需要更新與插入的id與數量

// 執行查詢倉庫與訂單的語句,獲取需要更細與插入的商品編號與數量

public void getNewNumber() {

// 從mysql數據庫倉庫中查詢數據并儲存起來

mysqlMap = jc.mysqlSelect("select * from cangku");

// 從mysql數據庫訂單表中獲取數據并存儲起來

mysqlDingDanMap = jc.mysqlSelectDingDan("select * from dingdan");

// 獲取倉庫表的所有數據

Set mysqlSet = mysqlMap.keySet();

// 獲取訂單表的數據

Set mysqlDingDanSet = mysqlDingDanMap.keySet();

for (Integer mn : mysqlSet) {

// 定義一個boolean類型的變量來表示當倉庫的商品編號在訂單表中不存在時,就設置為true

boolean flag = true;

for (Integer on : mysqlDingDanSet) {

if (mn.intValue() == on.intValue()) {

if (mysqlMap.get(mn).intValue() != mysqlDingDanMap.get(mn)

.intValue()) {

updateNewNumber.put(mn, mysqlMap.get(mn));

}

flag = false;

}

}

// 當flag為true時,就把訂單表中沒有的商品編號存起來

if (flag) {

insertNewNumber.put(mn, mysqlMap.get(mn));

}

}

}

接著是執行更新操作和插入操作,以及把結果以字符串的形式發送給客戶端

// 進行更新操作

public void updateNumber() {

// 執行查詢倉庫與訂單的語句,獲取需要更細與插入的商品編號與數量

getNewNumber();

// 獲取所有需要更新的商品編號

Set mysqlDingDanNumber = updateNewNumber.keySet();

for (Integer i : mysqlDingDanNumber) {

// 將需要更新的商品編號和數量更新到訂單表中

jc.getMsPool().getUPstmt(

"update dingdan set dingdannumber=? WHERE id=?", i,

updateNewNumber.get(i));

}

}

// 進行插入操作

public void insertNumber() {

// 獲取所有需要插入的商品編號

Set mysqlDingDanNumber = insertNewNumber.keySet();

for (Integer i : mysqlDingDanNumber) {

// 將需要插入的商品編號和數量插入到訂單表中

jc.getMsPool().getUPstmt(

"insert into dingdan(dingdannumber,id) values(?,?)", i,

insertNewNumber.get(i));

}

}

// 遍歷需要更新的數據,以字符串形式存儲,以便將來發送給客戶端

public StringBuffer getUpdateInsertNumber() {

// 進行更新操作

updateNumber();

// 進行插入操作

insertNumber();

// 獲取所有需要更新的商品編號

Set mysqlDingDanNumber = updateNewNumber.keySet();

for (Integer i : mysqlDingDanNumber) {

SBUpdateNumber.append("更新了商品編號為:" + i + "的商品-----此次更新的數量為:"

+ updateNewNumber.get(i) + "\r\n");

}

// 獲取所有需要插入的商品編號

Set mysqlDingDanInsertNumber = insertNewNumber.keySet();

for (Integer i : mysqlDingDanInsertNumber) {

SBUpdateNumber.append("插入了新的商品編號為:" + i + "的商品-----此次插入的數量為:"

+ insertNewNumber.get(i) + "\r\n");

}

return SBUpdateNumber;

}

最后,當然是上圖了

下面這張圖是我僅僅實現了更新功能時候的測試

然后是執行更新與插入的圖

這個小小的程序經過改了又改,雖然有點浪費時間,但是實現效果后,自己感覺還是挺開心的.....雖然已經很晚了,但是頓時感覺很清醒..........好,可以去睡覺了...........加油!,.......................

與50位技術專家面對面20年技術見證，附贈技術全景圖

總結

以上是生活随笔為你收集整理的java代码数据库添加操作_java连接数据库后进行更新插入操作的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。