JDBC的簡單講解

jdbc就是Java  Database Connective的縮寫傀缩，要使用java程序?qū)?shù)據(jù)庫進(jìn)行操作后德。

在使用JDBC的時(shí)候需要用到數(shù)據(jù)庫廠商提供的架包硝全。這里主要是對Mysql和Oracle數(shù)據(jù)進(jìn)行將解怪嫌。mysql主要講的是注冊驅(qū)動(dòng)，和獲取連接柳沙，后面的步驟和Oracle一樣。
mysql：

導(dǎo)入架包
class MysqlDemo{

  private static final String DRIVER = "com.mysql.jdbc.Driver";

  private static final String URL = "jdbc:mysql://(IP地址拌倍，注：IP地址是綁定的赂鲤，不是動(dòng)態(tài)綁定的)localhost:3306/數(shù)據(jù)庫名稱噪径，root(登入用戶名),123(密碼)"
  public static void main(String[] args){

    / /注冊驅(qū)動(dòng)   
    Class.forName(DRIVER);
    
  // 獲取連接
  Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/db","root","123");

  // 獲取執(zhí)行sql語句對象
  Statement stam = conn.createStatement();

  ResultSet rs = stam.executeQuery("查詢語句");

  while(rs.next()){
  
}
rs.close();
stam.close();
conn.close();
  }
  
}

上面是mysql的規(guī)范。
下面介紹Oracle的規(guī)范：

package com.zhaoqian.jdbc.p1;

import java.sql.Connection;
import java.sql.DriverManager;

public class Demo1 {

    private static final String DRIVER = "oracle.jdbc.driver.OracleDriver";
    private static final String URL = "jdbc:oracle:thin:@localhost:1521:orcl";
    private static final String USER = "scott";
    private static final String PASSWORD = "TIGER";

    public static void main(String[] args) throws Exception {
        // 加載驅(qū)動(dòng)
        
            Class.forName(DRIVER);
        
        // 獲取鏈接
        
            Connection conn = DriverManager.getConnection(URL, USER, PASSWORD);
            System.out.println(conn);
        
    }

}

下面是JDBC的簡單應(yīng)用（Statement）

package com.zhaoqiang.util;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;

public class JDBCUtil {
    private static Connection conn;
    
    private static final String DRIVER = "oracle.jdbc.driver.OracleDriver";
    
    private static final String URL = "jdbc:oracle:thin:@localhost:1521:orcl";
    
    private static final String USER = "scott";
    
    private static final String PASSWORD = "TIGER";
    
    // 靜態(tài)代碼塊加載驅(qū)動(dòng)
    static {
        
        try {
            Class.forName(DRIVER);
        } catch (ClassNotFoundException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
    
    // 返回鏈接對象
    public static Connection getConnection(){
        try {
            conn = DriverManager.getConnection(URL, USER, PASSWORD);
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return conn;
    }
    
    
    public static void close(){
        
        if (conn != null) {
            try {
                conn.close();
            } catch (SQLException e) {
                throw new RuntimeException("關(guān)閉連接失敗数初，請重試");
            }
        }
    }
}

________________________________
package com.zhaoqiang.util;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;

import com.zhaoqiang.vo.Person;

public class JDBCTable {
    
    private static Statement stam;
    
    private static int len = 0;
    
    public JDBCTable(Statement stam) {
        this.stam = stam;
    }
    
    // 添加數(shù)據(jù),修改數(shù)據(jù)找爱，刪除數(shù)據(jù)
    public static int getexecuteUpdate(String sql){
        
        try {
             len = stam.executeUpdate(sql);
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return len;
    }
    
    // 查詢數(shù)據(jù)
    public static List<Person> getexecuteQuery(String sql) throws Exception{
        ResultSet rs = stam.executeQuery(sql);
        Person per = null;
        ArrayList<Person> ar = new ArrayList<Person>();
        while(rs.next()){
             per = new Person();
             per.setPid(rs.getInt(1));
             per.setName(rs.getString(2));
             per.setAge(rs.getInt(3));
             ar.add(per);
        }
        
        return ar;
    }
    
}
___________________________________
package com.zhaoqian.jdbc.p1;

import java.sql.Connection;
import java.sql.Statement;

import com.zhaoqiang.util.JDBCTable;
import com.zhaoqiang.util.JDBCUtil;

public class Demo2 {

    public static void main(String[] args) {
        // 測試Statement類
        Connection conn = JDBCUtil.getConnection();
        
        try {
            Statement stam = conn.createStatement();
            JDBCTable jd = new JDBCTable(stam);
            
            String sql = "DELETE FROM person WHERE ENAME='張三'";
            int len = jd.getexecuteUpdate(sql);
            System.out.println(len);
            
        } catch (Exception e) {
            e.printStackTrace();
        }
    
        
    }

}

然而在開發(fā)中，我們并不會(huì)使用Statement類泡孩，而是使用期子類PreparedStatement來執(zhí)行sql語句车摄，原因：
1,可以讓執(zhí)行sql語句更加安全。（讓運(yùn)行時(shí)的錯(cuò)誤在編譯時(shí)出現(xiàn)仑鸥，或者說會(huì)先運(yùn)行一遍SQL語句）
2,可以執(zhí)行一些Statement類無法執(zhí)行的敏感字符
范例：

package com.zhaoqian.jdbc.p1;

import java.sql.Connection;
import java.sql.Statement;

import com.zhaoqiang.util.JDBCTable;
import com.zhaoqiang.util.JDBCUtil;

public class Demo2 {

    public static void main(String[] args) {
        // 測試Statement類
        Connection conn = JDBCUtil.getConnection();
        
        try {
            Statement stam = conn.createStatement();
            JDBCTable jd = new JDBCTable(stam);
            
            String sql = "DELETE FROM person WHERE ENAME='mr'SMITH'"; // 敏感字符
            int len = jd.getexecuteUpdate(sql);
            System.out.println(len);
            
        } catch (Exception e) {
            e.printStackTrace();
        }
    
        
    }

}

事務(wù)的回滾：當(dāng)批量執(zhí)行SQL語句的時(shí)候吮播，其中出現(xiàn)了一個(gè)錯(cuò)誤，我們需要讓前面添加的數(shù)據(jù)全部回滾：
由于在java程序中數(shù)據(jù)庫的事務(wù)是自動(dòng)提交的眼俊，如果要手工提交意狠，那么要先取消java的自動(dòng)提交功能

/**
     * 實(shí)現(xiàn)數(shù)據(jù)的增加
     * @param sql  
     * @return  返回收到影響的行數(shù)
     * @throws Exception
     */
    public  static  int[] doCreate() throws Exception{
         Statement stm=conn.createStatement();
         int result[] =null;
         conn.setAutoCommit(false);//取消自動(dòng)提交
         try{
             stm.addBatch("INSERT INTO person(pid,name,age) VALUES(myseq.nextval,'SMITH',23)");
             stm.addBatch("INSERT INTO person(pid,name,age) VALUES(myseq.nextval,'SMITH',23)");
             stm.addBatch("INSERT INTO person(pid,name,age) VALUES(myseq.nextval,'SMITH',23)");
             stm.addBatch("INSERT INTO person(pid,name,age) VALUES(myseq.nextvalwee,'SMITH',23)");
             stm.addBatch("INSERT INTO person(pid,name,age) VALUES(myseq.nextval,'SMITH',23)");
             stm.addBatch("INSERT INTO person(pid,name,age) VALUES(myseq.nextval,'SMITH',23)");
             result =stm.executeBatch();
             conn.commit();//事務(wù)提交
         }catch(Exception e){
             conn.rollback();
             e.printStackTrace();
         }
         return result;
    }

下面介紹一下PreparedStatement的簡單應(yīng)用：

package com.zhaoqiang.util;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.ArrayList;
import java.util.List;

import com.zhaoqiang.vo.Person;

public class JDBCTable_P {

    private static Connection conn = null;
    
    public JDBCTable_P(Connection conn) {
        this.conn = conn;
    }
    
    /**
     * 數(shù)據(jù)庫插入操作
     * @return  受到作用的行數(shù)
     * @throws Exception
     */
    public static int doInsert() throws Exception{
        
        String sql = "INSERT INTO preson(pid,name,age) VALUES(myseq.nextval,?,?)";
        PreparedStatement prs = conn.prepareStatement(sql);
        
        prs.setString(1, "張三");
        prs.setInt(2, 28);
        
        return prs.executeUpdate();
    }
    
    /**
     * 數(shù)據(jù)庫修改（更新）操作
     * @param age
     * @param name
     * @return 受到作用的行數(shù)
     * @throws Exception
     */
    public static int doUpDate(int age,String name) throws Exception{
        
        String sql = "UPDATE person SET AGE = ? WHERE name=?";
        PreparedStatement prs = conn.prepareStatement(sql);
        prs.setInt(1, 50);
        prs.setString(2, "張三");
        
        return prs.executeUpdate();
    }
    
    /**
     * 數(shù)據(jù)刪除操作
     * @param age
     * @return  受到作用的行數(shù)
     * @throws Exception
     */
    public static int doRemove(int age) throws Exception{
        String sql = "DELETE FROM person WHERE age = ?";
        
        PreparedStatement prs = conn.prepareStatement(sql);
        prs.setInt(1, 50);
        
        return prs.executeUpdate();
    }
    
    /**
     * 數(shù)據(jù)庫單行查詢操作
     * @return Person對象
     * @throws Exception
     */
    public static Person doFind() throws Exception{
        
        String sql = "SELECT pid,name,age FROM person WHERE age=?";
        PreparedStatement prs = conn.prepareStatement(sql);
        prs.setInt(1, 50);
        
        ResultSet rs = prs.executeQuery();
        
        Person per = new Person();
        
        while(rs.next()){
            per.setPid(rs.getInt(1));
            per.setName(rs.getString(2));
            per.setAge(rs.getInt(3));
        }
        
        return per;
    }
    
    /**
     * 數(shù)據(jù)庫查詢?nèi)繑?shù)據(jù)
     * @return 一個(gè)裝著Person對象的List集合
     * @throws Exception
     */
    public static List<Person> doFindAll() throws Exception{
        String sql = "SELECT pid,name,age FROM person";
        PreparedStatement prs = conn.prepareStatement(sql);
        ResultSet rs = prs.executeQuery();
        
        Person per = null;
        
        ArrayList<Person> list = new ArrayList<Person>();
        
        while(rs.next()){
            per = new Person();
            per.setPid(rs.getInt(1));
            per.setName(rs.getString(2));
            per.setAge(rs.getInt(3));
            
            list.add(per);
        }
        return list;
    }
    
    /**
     * 數(shù)據(jù)庫模糊查詢
     * @param str
     * @return  一個(gè)裝著Person對象的List集合
     * @throws Exception
     */
    public static List<Person> doFindAll(String str) throws Exception{
        String sql = "SELECT pid,name,age FROM person WHERE name LIKE ?";
        PreparedStatement prs = conn.prepareStatement(sql);
        prs.setString(1, "%"+str+"%");
        
        ResultSet rs = prs.executeQuery();
        
        Person per = null;
        
        ArrayList<Person> list = new ArrayList<Person>();
        
        while(rs.next()){
            per = new Person();
            per.setPid(rs.getInt(1));
            per.setName(rs.getString(2));
            per.setAge(rs.getInt(3));
            
            list.add(per);
        }
        return list;
    }
    
    /**
     * 數(shù)據(jù)庫分頁查詢操作
     * @param currentPage 當(dāng)前頁
     * @param lineSize  每頁的行數(shù)
     * @return  一個(gè)裝著Person對象的List集合
     * @throws Exception
     */
    public static List<Person> doFindAll(int currentPage,int lineSize) throws Exception{
        String sql = "SELECT * FROM "
                + " ( SELECT ROWNUM rn,pid,name,age FROM person WHERE rn<=?)temp "
                + " WHERE temp.rn>=?";
        PreparedStatement prs = conn.prepareStatement(sql);
        prs.setInt(1, currentPage*lineSize);
        prs.setInt(2, (currentPage-1)*lineSize+1);
        
        ResultSet rs = prs.executeQuery();
        
        Person per = null;
        
        ArrayList<Person> list = new ArrayList<Person>();
        
        while(rs.next()){
            per = new Person();
            per.setPid(rs.getInt(1));
            per.setName(rs.getString(2));
            per.setAge(rs.getInt(3));
            
            list.add(per);
        }
        return list;
    }
    
    /**
     * 數(shù)據(jù)庫模糊分頁查詢
     * @param currentPage 當(dāng)前頁
     * @param lineSize  每頁的行數(shù)
     * @param str   模糊查詢的關(guān)鍵字
     * @return 一個(gè)裝著Person對象的List集合
     * @throws Exception
     */
    public static List<Person> doFindAll(int currentPage,int lineSize,String str) throws Exception{
        String sql = "SELECT * FROM ("
                + " SELECT ROWNUM rn,EMPNO,ENAME,JOB,SAL FROM ("
                + " SELECT * FROM EMP WHERE ENAME LIKE ?)"
                + " WHERE ROWNUM <= ?)temp "
                + " WHERE temp.rn>=?";
        PreparedStatement prs = conn.prepareStatement(sql);
        prs.setString(1, "%"+str+"%");
        prs.setInt(2, currentPage*lineSize);
        prs.setInt(3, (currentPage-1)*lineSize+1);
        
        ResultSet rs = prs.executeQuery();
        
        Person per = null;
        
        ArrayList<Person> list = new ArrayList<Person>();
        
        while(rs.next()){
            per = new Person();
            per.setPid(rs.getInt(1));
            per.setName(rs.getString(2));
            per.setAge(rs.getInt(3));
            
            list.add(per);
        }
        return list;
    }
}
_____________________________
package com.zhaoqian.jdbc.p1;

import java.security.KeyStore.ProtectionParameter;
import java.sql.Connection;
import java.sql.PreparedStatement;

import com.zhaoqiang.util.JDBCTable_P;
import com.zhaoqiang.util.JDBCUtil;

public class Demo3 {

    public static void main(String[] args) throws Exception {
    
        Connection conn = JDBCUtil.getConnection();
        
        JDBCTable_P jdbc = new JDBCTable_P(conn);
        
        jdbc.doInsert();
        jdbc.doUpDate(50, "張三");
        jdbc.doFindAll();
    }

}

最后編輯于：2017.12.06 06:39:49

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者

人面猴
序言：七十年代末，一起剝皮案震驚了整個(gè)濱河市疮胖，隨后出現(xiàn)的幾起案子环戈，更是在濱河造成了極大的恐慌，老刑警劉巖澎灸，帶你破解...
沈念sama閱讀 216,470評論 6贊 501
死咒
序言：濱河連續(xù)發(fā)生了三起死亡事件院塞，死亡現(xiàn)場離奇詭異，居然都是意外死亡性昭，警方通過查閱死者的電腦和手機(jī)拦止，發(fā)現(xiàn)死者居然都...
沈念sama閱讀 92,393評論 3贊 392
救了他兩次的神仙讓他今天三更去死
文/潘曉璐我一進(jìn)店門，熙熙樓的掌柜王于貴愁眉苦臉地迎上來巩梢，“玉大人创泄，你說我怎么就攤上這事±穑” “怎么了鞠抑？”我有些...
開封第一講書人閱讀 162,577評論 0贊 353
道士緝兇錄：失蹤的賣姜人
文/不壞的土叔我叫張陵，是天一觀的道長忌警。經(jīng)常有香客問我搁拙，道長，這世上最難降的妖魔是什么法绵？我笑而不...
開封第一講書人閱讀 58,176評論 1贊 292
?港島之戀（遺憾婚禮）
正文為了忘掉前任箕速，我火速辦了婚禮，結(jié)果婚禮上朋譬，老公的妹妹穿的比我還像新娘盐茎。我一直安慰自己，他們只是感情好徙赢，可當(dāng)我...
茶點(diǎn)故事閱讀 67,189評論 6贊 388
惡毒庶女頂嫁案：這布局不是一般人想出來的
文/花漫我一把揭開白布字柠。她就那樣靜靜地躺著探越，像睡著了一般。火紅的嫁衣襯著肌膚如雪窑业。梳的紋絲不亂的頭發(fā)上钦幔，一...
開封第一講書人閱讀 51,155評論 1贊 299
城市分裂傳說
那天，我揣著相機(jī)與錄音常柄，去河邊找鬼鲤氢。笑死，一個(gè)胖子當(dāng)著我的面吹牛西潘，可吹牛的內(nèi)容都是我干的卷玉。我是一名探鬼主播，決...
沈念sama閱讀 40,041評論 3贊 418
雙鴛鴦連環(huán)套：你想象不到人心有多黑
文/蒼蘭香墨我猛地睜開眼秸架，長吁一口氣：“原來是場噩夢啊……” “哼揍庄！你這毒婦竟也來了？” 一聲冷哼從身側(cè)響起东抹，我...
開封第一講書人閱讀 38,903評論 0贊 274
萬榮殺人案實(shí)錄
序言：老撾萬榮一對情侶失蹤蚂子，失蹤者是張志新（化名）和其女友劉穎，沒想到半個(gè)月后缭黔，有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體食茎，經(jīng)...
沈念sama閱讀 45,319評論 1贊 310
?護(hù)林員之死
正文獨(dú)居荒郊野嶺守林人離奇死亡，尸身上長有42處帶血的膿包…… 初始之章·張勛以下內(nèi)容為張勛視角年9月15日...
茶點(diǎn)故事閱讀 37,539評論 2贊 332
?白月光啟示錄
正文我和宋清朗相戀三年馏谨，在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了别渔。大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
茶點(diǎn)故事閱讀 39,703評論 1贊 348
活死人
序言：一個(gè)原本活蹦亂跳的男人離奇死亡惧互，死狀恐怖哎媚，靈堂內(nèi)的尸體忽然破棺而出，到底是詐尸還是另有隱情喊儡，我是刑警寧澤拨与，帶...
沈念sama閱讀 35,417評論 5贊 343
?日本核電站爆炸內(nèi)幕
正文年R本政府宣布，位于F島的核電站艾猜，受9級特大地震影響买喧，放射性物質(zhì)發(fā)生泄漏。R本人自食惡果不足惜匆赃，卻給世界環(huán)境...
茶點(diǎn)故事閱讀 41,013評論 3贊 325
男人毒藥：我在死后第九天來索命
文/蒙蒙一淤毛、第九天我趴在偏房一處隱蔽的房頂上張望。院中可真熱鬧算柳，春花似錦低淡、人聲如沸。這莊子的主人今日做“春日...
開封第一講書人閱讀 31,664評論 0贊 22
一樁弒父案查牌，背后竟有這般陰謀
文/蒼蘭香墨我抬頭看了看天上的太陽事期。三九已至，卻和暖如春纸颜，著一層夾襖步出監(jiān)牢的瞬間，已是汗流浹背绎橘。一陣腳步聲響...
開封第一講書人閱讀 32,818評論 1贊 269
情欲美人皮
我被黑心中介騙來泰國打工胁孙，沒想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留，地道東北人称鳞。一個(gè)月前我還...
沈念sama閱讀 47,711評論 2贊 368
代替公主和親
正文我出身青樓涮较，卻偏偏與公主長得像，于是被迫代替她去往敵國和親冈止。傳聞我的和親對象是個(gè)殘疾皇子狂票，可洞房花燭夜當(dāng)晚...
茶點(diǎn)故事閱讀 44,601評論 2贊 353

JDBC的簡單講解

推薦閱讀更多精彩內(nèi)容