Java連接MySql數(shù)據(jù)庫(kù),并且實(shí)現(xiàn)增刪改查功能

1、Java 連接 MySql 數(shù)據(jù)庫(kù)，并且實(shí)現(xiàn)增刪改查功能！這是我最近寫(xiě)的一個(gè)連接 MySql 數(shù)據(jù)庫(kù)的一個(gè)例子，主要實(shí)現(xiàn)了插入，刪除，更新，選擇操作，用的環(huán)境是 j2sdk1.4.2_08,Eclipse3.1。下面我把在 Eclipse3.1下怎樣配置數(shù)據(jù)庫(kù)連接信息簡(jiǎn)單說(shuō)一下。1 .啟動(dòng) Eclipse3.1o2 .建立一個(gè) Javaproject叫 DbConnect 吧，再在該 Project 下建立一個(gè)新類(lèi)也叫DbConnect 吧。3 .右擊 DbConnect.java 文件點(diǎn) import,選擇 Archivefile 然后選擇你的mysql-connector-java-3.1

2、.8-bin.jar 文件，點(diǎn) Finish。你會(huì)看到有好些文件被加載進(jìn)來(lái)，OK 這就是連接 MySql 所需的驅(qū)動(dòng)信息。如果到了這里你都成功的話(huà)那么恭喜你，你已經(jīng)成功一半了?。?4 .接下來(lái)把我下面的代碼 copy 到你的 Java 文件中，修改相關(guān)的數(shù)據(jù)庫(kù)連接信息運(yùn)行一下。OK?我說(shuō)一下那個(gè) mysql-connector-java-3.1.8-bin.jar 文件， 其實(shí)這就是一個(gè) MySql 的驅(qū)動(dòng)，各數(shù)據(jù)庫(kù)廠(chǎng)商提供了不同的適用于 JDBC 的驅(qū)動(dòng)使得在 Java 中連接數(shù)據(jù)庫(kù)非常簡(jiǎn)單。這里我就不多說(shuō)了，以后我會(huì)寫(xiě)篇專(zhuān)門(mén)介紹數(shù)據(jù)庫(kù)驅(qū)動(dòng)的文章。關(guān)于 MySql 的驅(qū)動(dòng)還有更新版本的，你需

3、要到 MySql 的網(wǎng)站上去下載，這個(gè)網(wǎng)上到處都是，我就不多說(shuō)了。下面看程序，有些地方我寫(xiě)了詳細(xì)的注釋?xiě)?yīng)該能看懂。這個(gè)類(lèi)是非常有特色的，在每個(gè)方法的傳人參數(shù)和返回值不變的情況下，希望高手能提出改進(jìn)意見(jiàn)。多指教，謝謝！/*數(shù)據(jù)庫(kù)連接、選擇、更新、刪除演示|*/importjava.sql.*;importjava.sql.Connection;importjava.sql.Statement;importjava.sql.ResultSet;importjava.sql.DriverManager;importjava.util.*;publicclassDbConnect/數(shù)據(jù)成員 and 構(gòu)

4、造函數(shù)privateConnectiondbconn;privateStatementdbstate;privateResultSetdbresult;DbConnect()dbconn=null;dbstate=null;dbresult=null;/類(lèi)方法publicvoidprint(Stringstr)簡(jiǎn)化輸出(System.out.println(str);/endprint()/* 連接 MySql 數(shù)據(jù)庫(kù)* paramhost* paramport* paramdbaName* paramusName* parampsw* returnbool 值，連接成功返回真，失敗返回假*/

5、publicbooleandbConnection(Stringhost,Stringport,StringdbaName,StringusName,Stringpsw)(StringdriverName=com.mysql.jdbc.Driver;/org.gjt.mm.mysql.Driver”兩個(gè)驅(qū)動(dòng)都可以用StringdbHost=host;/微據(jù)庫(kù)的一些信息StringdbPort=port;StringdbName=dbaName;StringenCoding=?useUnicode=true&characterEncoding=gb2312”;/單決MySql 中文問(wèn)題，

6、要連續(xù)寫(xiě)不能空格StringuserName=usName;StringPsw=psw;Stringurl=jdbc:mysql:/+dbHost+:+dbPort+/+dbName+enCoding;try(Class.forName(driverName).newInstance();dbconn=DriverManager.getConnection(url,userName,Psw);/getConnection(url,userName,Psw 從給的 driver 中選擇合適的去連接數(shù)據(jù)庫(kù)/returnaconnectiontotheURLcatch(Exceptione)prin

7、t(url=+url);/發(fā)生錯(cuò)誤時(shí)，將連接數(shù)據(jù)庫(kù)信息打印出來(lái)print(userName=+userName);print(Psw+Psw);print(Exception:+e.getMessage();/馬到出錯(cuò)信息if(dbconn!=null)/dbconn!=null表示連接數(shù)據(jù)庫(kù)成功， 由異常保證??？returntrue;elsereturnfalse;/endbooleandbConnection()/* 對(duì)數(shù)據(jù)庫(kù)表進(jìn)行選擇操作！* paramtableName 數(shù)據(jù)庫(kù)表名* paramfieles 字段名* paramselCondition 選擇條件* return 一個(gè)含

8、有 map 的 List(列表)* /publicArrayListdbSelect(StringtableName,ArrayListfields,StringselCondition)ArrayListmapInList=newArrayList();StringselFields=;for(inti=0;i刪除操作booleandelResult=false;Stringsql=deletefrom+tableName+condition;trydbstate.executeUpdate(sql);/returnint/intdelRe=?delResult=true;catch(Exc

9、eptione)print(sql=+sql);print(Exception:+e.getMessage();if(delResult)returntrue;elsereturnfalse;一二(dbstate.executeUpdate(sql);updateResult=true;catch(Exceptionerr)print(sql=+sql);print(Exception:+err.getMessage();if(updateResult)returntrue;print(Exception:+e.getMessage();)if(insertResult)returntrue;

10、elsereturnfalse;/enddbInsert()/* 斷開(kāi)數(shù)據(jù)庫(kù)* returnbool 值，成功返回 true,失敗返回 false* /publicbooleandbClose()booleancloseResult=false;try/enddbDelete()/*對(duì)數(shù)據(jù)庫(kù)表中記錄進(jìn)行更新操作*paramtabName*paramreCountelsereturnfalse;/enddbUpdate()/*對(duì)數(shù)據(jù)庫(kù)表進(jìn)行插入操作*paramtabName*paramhmdbconn.close();closeResult=true;catch(Exceptione)print

11、(Exception:+e.getMessage();if(closeResult)returntrue;elsereturnfalse;/enddbClose()/*/入口主函數(shù)|*/publicstaticvoidmain(String 口 args)DbConnectdc=newDbConnect();/連接數(shù)據(jù)庫(kù)用到的一些參數(shù).StringdbHost=localhost;StringdbPort=3306;StringdbName=feast;StringdbuserName=root;Stringdbpsw=;booleancon=dc.dbConnection(dbHost,db

12、Port,dbName,dbuserName,dbpsw);/連接數(shù)據(jù)庫(kù)if(con)ArrayListfields=newArrayList();fields.add(message_content);fields.add(message_type);MapImap=newHashMap();StringselCondition=wheremessage_type=1limit2”;ArrayListstr=dc.dbSelect(Hfeast,fields,selCondition);/選擇 t 己if(str.size()!=0)dc.print(selectOK!”)；dc.print

13、(strssize=+str.size();for(inti=0;i更新數(shù)據(jù)if(ur)dc.print(updateOK);elsedc.print(updateerror!);HashMapmm=newHashMap();mm.put(message_number,6);mm.put(message_content,insertefasdfas);mm.put(message_type,4);booleanin=dc.dbInsert(feast,mm);/插入if(in)dc.print(insertOK);elsedc.print(inserterror!);booleanclose=

14、dc.dbClose();，斷開(kāi)數(shù)據(jù)庫(kù) if(close)dc.print(closeOK);elsedc.print(closefail);/endmain()/endclassDbConnect*returnbool 值，成功返回 true,失敗返回 false*/publicbooleandbUpdate(StringtabName,HashMapreCount,StringupCondition)booleanupdateResult=false;StringValues=;IteratorkeyValues=reCount.entrySet().iterator();for(inti

15、=0;ireCount.size();+i)Map.Entryentry=(Map.Entry)keyValues.next();Objectkey=entry.getKey();Objectvalue=entry.getValue();Values+=key+=+value+,;StringupdateValues=Values.substring(0,Values.length()-2);Stringsql=update+tabName+set+updateValues+upCondition;try*returnbool 值，成功返回 true,失敗返回 false*/publicboo

16、leandbInsert(StringtabName,HashMapvalues)Stringsql=;StringinsertFields=,temFields=;StringinsertValues=,temValues=;booleaninsertResult=false;IteratorkeyValues=values.entrySet().iterator();for(inti=0;ivalues.size();+i)Map.Entryentry=(Map.Entry)keyValues.next();Objectkey=entry.getKey();Objectvalue=entry.getValue();temFields+=key+,;temValues+=+value+,;inse