JDBC連接sql server數(shù)據(jù)庫(kù)的詳細(xì)步驟和代碼
JDBC連接sql server數(shù)據(jù)庫(kù)的步驟如下:
?1、加載JDBC驅(qū)動(dòng)程序:??? ????在連接數(shù)據(jù)庫(kù)之前,首先要加載想要連接的數(shù)據(jù)庫(kù)的驅(qū)動(dòng)到JVM(Java虛擬機(jī)),??? ????這通過(guò)java.lang.Class類的靜態(tài)方法forName(String??className)實(shí)現(xiàn)。 ???成功加載后,會(huì)將Driver類的實(shí)例注冊(cè)到DriverManager類中。??? ?2、提供JDBC連接的URL??? ????連接URL定義了連接數(shù)據(jù)庫(kù)時(shí)的協(xié)議、子協(xié)議、數(shù)據(jù)源標(biāo)識(shí)。??? ?????書(shū)寫(xiě)形式:協(xié)議:子協(xié)議:數(shù)據(jù)源標(biāo)識(shí)??? ????協(xié)議:在JDBC中總是以jdbc開(kāi)始??? ????子協(xié)議:是橋連接的驅(qū)動(dòng)程序或是數(shù)據(jù)庫(kù)管理系統(tǒng)名稱。??? ????數(shù)據(jù)源標(biāo)識(shí):標(biāo)記找到數(shù)據(jù)庫(kù)來(lái)源的地址與連接端口。????? ?3、創(chuàng)建數(shù)據(jù)庫(kù)的連接??? ?????要連接數(shù)據(jù)庫(kù),需要向java.sql.DriverManager請(qǐng)求并獲得Connection對(duì)象,??? ?????該對(duì)象就代表一個(gè)數(shù)據(jù)庫(kù)的連接。??? ?????使用DriverManager的getConnectin(String?url?,?String?username?,???? ????String?password?)方法傳入指定的欲連接的數(shù)據(jù)庫(kù)的路徑、數(shù)據(jù)庫(kù)的用戶名和??? ?????密碼來(lái)獲得。 ?4、創(chuàng)建一個(gè)Statement??? ?????要執(zhí)行SQL語(yǔ)句,必須獲得java.sql.Statement實(shí)例,Statement實(shí)例分為以下3?? ?????種類型:??? ??????1、執(zhí)行靜態(tài)SQL語(yǔ)句。通常通過(guò)Statement實(shí)例實(shí)現(xiàn)。??? ??????2、執(zhí)行動(dòng)態(tài)SQL語(yǔ)句。通常通過(guò)PreparedStatement實(shí)例實(shí)現(xiàn)。??? ??????3、執(zhí)行數(shù)據(jù)庫(kù)存儲(chǔ)過(guò)程。通常通過(guò)CallableStatement實(shí)例實(shí)現(xiàn)。??? ????具體的實(shí)現(xiàn)方式:??? ????????Statement?stmt?=?con.createStatement()?;??? ???????PreparedStatement?pstmt?=?con.prepareStatement(sql)?;??? ???????CallableStatement?cstmt?=?con.prepareCall("{CALL?demoSp(??,??)}")?;??? ?5、執(zhí)行SQL語(yǔ)句??? ????Statement接口提供了三種執(zhí)行SQL語(yǔ)句的方法:executeQuery?、executeUpdate??? ???和execute??? ????1、ResultSet?executeQuery():執(zhí)行查詢數(shù)據(jù)庫(kù)的SQL語(yǔ)句??? ????????,返回一個(gè)結(jié)果集(ResultSet)對(duì)象。??? ?????2、int?executeUpdate():用于執(zhí)行INSERT、UPDATE或??? ????????DELETE語(yǔ)句以及SQL?DDL語(yǔ)句,如:CREATE?TABLE和DROP?TABLE等??? ?????3、execute():用于執(zhí)行返回多個(gè)結(jié)果集、多個(gè)更新計(jì)數(shù)或二者組合的??? ????????語(yǔ)句。??? ???具體實(shí)現(xiàn)的代碼:??? ??????????ResultSet?rs?=?pstmt.executeQuery()?;??? ??????????int?rows?=?pstmt.executeUpdate()?;??? ??????????boolean?flag?=?pstmt.execute()?;??? ?6、處理結(jié)果??? ????兩種情況:??? ?????1、執(zhí)行更新返回的是本次操作影響到的記錄數(shù)。??? ?????2、執(zhí)行查詢返回的結(jié)果是一個(gè)ResultSet對(duì)象。??? ??????ResultSet包含符合SQL語(yǔ)句中條件的所有行,并且它通過(guò)一套get方法提供了對(duì)這些??? ??????行中數(shù)據(jù)的訪問(wèn)。??? ??????使用結(jié)果集(ResultSet)對(duì)象的訪問(wèn)方法獲取數(shù)據(jù):??? ?????while(rs.next()){??? ?????????String?name?=?rs.getString("name")?;??? ?????????String?pass?=?rs.getString(1)?; ?????}???? ?7、關(guān)閉JDBC對(duì)象???? ?????操作完成以后要把所有使用的JDBC對(duì)象全都關(guān)閉,以釋放JDBC資源,關(guān)閉順序和聲??? ?????明順序相反:??? ?????1、關(guān)閉記錄集??? ?????2、關(guān)閉聲明??? ?????3、關(guān)閉連接對(duì)象
JDBC連接sql server數(shù)據(jù)庫(kù)代碼:
package?com.accp.jdbc; import?java.sql.Connection; import?java.sql.DriverManager; import?java.sql.PreparedStatement; import?java.sql.ResultSet; import?java.sql.SQLException; import?org.apache.log4j.Logger; public?class?BaseDao?{ //?使用log4j記錄日志 private?static?Logger?logger?=?Logger.getLogger(BaseDao.class); //?連接驅(qū)動(dòng) private?static?final?String?DRIVER?=?"com.microsoft.sqlserver.jdbc.SQLServerDriver"; //?連接路徑 private?static?final?String?URL?=?"jdbc:sqlserver://localhost:1433;databaseName=MySchool"; //?用戶名 private?static?final?String?USERNAME?=?"sa"; //?密碼 private?static?final?String?PASSWORD?=?"sa"; //靜態(tài)代碼塊 static?{ try?{ //?加載驅(qū)動(dòng) Class.forName(DRIVER); }?catch?(ClassNotFoundException?e)?{ e.printStackTrace(); } } /* ?*?獲取數(shù)據(jù)庫(kù)連接 ?*/ public?Connection?getConnection()?{ Connection?conn?=?null; logger.debug("開(kāi)始連接數(shù)據(jù)庫(kù)"); try{ conn=DriverManager.getConnection(URL,?USERNAME,?PASSWORD); }catch(SQLException?e){ e.printStackTrace(); logger.error("數(shù)據(jù)庫(kù)連接失??!"); } logger.debug("數(shù)據(jù)庫(kù)連接成功"); return?conn; } /* ?*?關(guān)閉數(shù)據(jù)庫(kù)連接,注意關(guān)閉的順序 ?*/ public?void?close(ResultSet?rs,?PreparedStatement?ps,?Connection?conn)?{ if(rs!=null){ try{ rs.close(); rs=null; }catch(SQLException?e){ e.printStackTrace(); logger.error("關(guān)閉ResultSet失敗"); } } if(ps!=null){ try{ ps.close(); ps=null; }catch(SQLException?e){ e.printStackTrace(); logger.error("關(guān)閉PreparedStatement失敗"); } } if(conn!=null){ try{ conn.close(); conn=null; }catch(SQLException?e){ e.printStackTrace(); logger.error("關(guān)閉Connection失敗"); } } } }