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

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

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

3、要到 MySql 的網(wǎng)站上去下載，這個網(wǎng)上到處都是，我就不多說了。下面看程序，有些地方我寫了詳細的注釋應(yīng)該能看懂。這個類是非常有特色的，在每個方法的傳人參數(shù)和返回值不變的情況下，希望高手能提出改進意見。多指教，謝謝！/*數(shù)據(jù)庫連接、選擇、更新、刪除演示|*/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;/類方法publicvoidprint(Stringstr)簡化輸出(System.out.println(str);/endprint()/* 連接 MySql 數(shù)據(jù)庫* paramhost* paramport* paramdbaName* paramusName* parampsw* returnbool 值，連接成功返回真，失敗返回假*/

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

6、要連續(xù)寫不能空格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ù)庫/returnaconnectiontotheURLcatch(Exceptione)prin

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

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()/* 斷開數(shù)據(jù)庫* returnbool 值，成功返回 true,失敗返回 false* /publicbooleandbClose()booleancloseResult=false;try/enddbDelete()/*對數(shù)據(jù)庫表中記錄進行更新操作*paramtabName*paramreCountelsereturnfalse;/enddbUpdate()/*對數(shù)據(jù)庫表進行插入操作*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ù)庫用到的一些參數(shù).StringdbHost=localhost;StringdbPort=3306;StringdbName=feast;StringdbuserName=root;Stringdbpsw=;booleancon=dc.dbConnection(dbHost,db

12、Port,dbName,dbuserName,dbpsw);/連接數(shù)據(jù)庫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();，斷開數(shù)據(jù)庫 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