JDBC學(xué)習(xí)

1.認(rèn)識JDBC

JDBC: Java Database Connect Java連接數(shù)據(jù)庫

圖片.png

需要jar包支持：

  • java.sql
  • javax.sql
  • mysql-connector-java
<!-- https://mvnrepository.com/artifact/mysql/mysql-connector-java -->
<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>8.0.26</version>
</dependency>

https://repo1.maven.org/maven2/mysql/mysql-connector-java/8.0.26/mysql-connector-java-8.0.26.jar

2. 準(zhǔn)備測試數(shù)據(jù)庫

2.1 創(chuàng)建數(shù)據(jù)庫

CREATE DATABASE jdbc;

2.2 創(chuàng)建數(shù)據(jù)表

CREATE TABLE IF NOT EXISTS `user`(
   `id` INT UNSIGNED AUTO_INCREMENT,
   `username` VARCHAR(100) NOT NULL,
   `password` VARCHAR(40) NOT NULL,
   PRIMARY KEY ( `id` )
)ENGINE=InnoDB DEFAULT CHARSET=utf8;

2.3 插入數(shù)據(jù)

INSERT INTO user(username,password )
VALUES( "張三", "123456"),
( "李四", "123456"),
( "張三瘋", "123456");

3. 編寫JDBC

  • JDBC_statement_CRUD
package com.zzqsmile;

import java.sql.*;

public class JDBC_statement_CRUD {
    public static void main(String[] args) throws ClassNotFoundException, SQLException {
        //1. 加載驅(qū)動
        Class.forName("com.mysql.cj.jdbc.Driver");

        //2. 配置信息
        String url="jdbc:mysql://localhost:3306/jdbc?useUnicode=true&characterEncoding=utf-8&useSSL=false";
        String username="root";
        String password="root";

        //3. 連接數(shù)據(jù)庫,Connection代表數(shù)據(jù)庫
        Connection connection = DriverManager.getConnection(url, username, password);

        //4. 向數(shù)據(jù)庫發(fā)送sql的對象Statement&&PreparedStatement,用來CRUD
        Statement statement = connection.createStatement();
        //編寫查詢sql   --查
        String sql="select * from user;";
        //執(zhí)行
        ResultSet resultSet = statement.executeQuery(sql);
        //打印信息
        while (resultSet.next()){
            System.out.println("id="+resultSet.getObject("id"));
            System.out.println("username="+resultSet.getObject("username"));
            System.out.println("password="+resultSet.getObject("password"));
            System.out.println("=======================");
            System.out.println();
        }

        //編寫插入sql   --增
        String sql1="insert into user(username,password) values('劉五','111111')";
        //執(zhí)行
        int i = statement.executeUpdate(sql1);
        if (i>0){
            System.out.println("插入成功泰鸡！");
            System.out.println();
        }

        //編寫修改sql   --改
        String sql2="update user set `password`='123123' where `username`='劉五'";
        //執(zhí)行
        int i1 = statement.executeUpdate(sql2);
        if (i1>0){
            System.out.println("修改成功谤辜！");
            System.out.println();
        }

        //編寫刪除sql   --刪
        String sql3="delete from user where id = 1";
        //執(zhí)行
        int i2 = statement.executeUpdate(sql3);
        if (i2>0){
            System.out.println("刪除成功！");
            System.out.println();
        }


        //5. 關(guān)閉連接
        resultSet.close();
        statement.close();
        connection.close();
    }
}

- JDBC_PreparedStatement_CRUD

預(yù)編譯CURD

package com.zzqsmile;

import java.sql.*;

public class JDBC_PreparedStatement_CRUD {
    public static void main(String[] args) throws ClassNotFoundException, SQLException {
        //1. 加載驅(qū)動
        Class.forName("com.mysql.cj.jdbc.Driver");

        //2. 配置信息
        String url="jdbc:mysql://localhost:3306/jdbc?useUnicode=true&characterEncoding=utf-8&useSSL=false";
        String username="root";
        String password="root";

        //3. 連接數(shù)據(jù)庫,Connection代表數(shù)據(jù)庫
        Connection connection = DriverManager.getConnection(url, username, password);

        //4. 編寫參數(shù)化SQL(帶?的SQL語句)
        //編寫查詢sql   --查
        String sql="select * from user where username = ?";
        PreparedStatement preparedStatement = connection.prepareStatement(sql);

        //賦值
        preparedStatement.setString(1,"李四");

        //執(zhí)行
        ResultSet resultSet = preparedStatement.executeQuery();
        //打印信息
        while (resultSet.next()){
            System.out.println("===========查詢結(jié)果============");
            System.out.println("id="+resultSet.getObject("id"));
            System.out.println("username="+resultSet.getObject("username"));
            System.out.println("password="+resultSet.getObject("password"));
            System.out.println();
        }

        //編寫插入sql   --增
        String sql1="insert into user(username,password) values(?,?)";
        PreparedStatement preparedStatement1 = connection.prepareStatement(sql1);

        //賦值
        preparedStatement1.setString(1,"李四2");
        preparedStatement1.setString(2,"123321");
        //執(zhí)行
        int i1 = preparedStatement1.executeUpdate();
        if (i1>0){
            System.out.println("插入成功哮奇！");
            System.out.println();
        }

        //編寫修改sql   --改
        String sql2="update user set `password`=? where `username`='劉五'";
        PreparedStatement preparedStatement2 = connection.prepareStatement(sql2);

        //賦值
        preparedStatement2.setString(1,"222222");
        //執(zhí)行
        int i2 = preparedStatement2.executeUpdate();
        if (i2>0){
            System.out.println("修改成功饭耳！");
            System.out.println();
        }

        //編寫刪除sql   --刪
        String sql3="delete from user where id = ?";
        PreparedStatement preparedStatement3 = connection.prepareStatement(sql3);

        //賦值
        preparedStatement3.setString(1,"2");
        //執(zhí)行
        int i3 = preparedStatement3.executeUpdate();
        if (i3>0){
            System.out.println("刪除成功串述！");
            System.out.println();
        }

        //5. 關(guān)閉連接
        resultSet.close();
        preparedStatement.close();
        preparedStatement1.close();
        preparedStatement2.close();
        preparedStatement3.close();
        connection.close();
    }
}

3. 提取工具類JDBC_utils

  • src目錄下創(chuàng)建db.properties文件
driver=com.mysql.cj.jdbc.Driver
url=jdbc:mysql://localhost:3306/jdbc?useUnicode=true&characterEncoding=utf-8&useSSL=false
username=root
password=root

JDBC_utils:

package com.zzqsmile.lesson2.utils;

import java.io.InputStream;
import java.sql.*;
import java.util.Properties;

public class JDBC_utils {

    private static String driver = null;
    private static String url = null;
    private static String username = null;
    private static String password = null;

    static {
        try {
            InputStream resourceAsStream = JDBC_utils.class.getClassLoader().getResourceAsStream("db.properties");
            Properties properties = new Properties();
            properties.load(resourceAsStream);

            driver = properties.getProperty("driver");
            url = properties.getProperty("url");
            username = properties.getProperty("username");
            password = properties.getProperty("password");

            //1.驅(qū)動只用加載一次
            Class.forName(driver);

        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    // 2. 獲取連接
    public static Connection getConnection() throws SQLException {
        return DriverManager.getConnection(url,username,password);

    }

    //3. 釋放資源，關(guān)閉鏈接`close(Connection conn,Statement stmt,ResultSet rs)`
    public static void close(Connection conn, Statement stmt, ResultSet rs) {
        if (rs != null) {
            try {
                rs.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        if (stmt != null) {
            try {
                stmt.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        if (conn != null) { // 防止空指針
            try {
                conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

    // 4.重載關(guān)閉方法`close(Connection conn, Statement stmt)`
    public static void close(Connection conn, Statement stmt) {
        close(conn, stmt, null);
    }
}
  • 使用JDBC_utils改進(jìn)編寫Statement的CURD:
package com.zzqsmile.lesson2;

import com.zzqsmile.lesson2.utils.JDBC_utils;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class Test_Statement {
    public static void main(String[] args) {

        Connection conn = null;
        Statement st = null;
        ResultSet rs = null;

        try {
            conn = JDBC_utils.getConnection();  //獲得數(shù)據(jù)庫連接
            st = conn.createStatement();    //獲得SQL執(zhí)行對象

            //增
            String sql = "insert into user(username,password) values('admin1','333333')";
            int i = st.executeUpdate(sql);

            if (i>0){
                System.out.println("插入成功寞肖！");
                System.out.println();
            }

            //刪
            String sql1 = "delete from user where id = '10'";
            int i1 = st.executeUpdate(sql1);

            if (i1>0){
                System.out.println("刪除成功纲酗！");
                System.out.println();
            }

            //改
            String sql2 = "update user set password = '135790' where username = 'admin1'";
            int i2 = st.executeUpdate(sql2);

            if (i2>0){
                System.out.println("修改成功！");
                System.out.println();
            }

            //查
            String sql3 = "select * from user where username = 'admin1'";
            ResultSet resultSet = st.executeQuery(sql3);

            if (resultSet.next()){
                System.out.println("查詢成功新蟆！");
                System.out.println("id="+resultSet.getObject("id"));
                System.out.println("username="+resultSet.getObject("username"));
                System.out.println("password="+resultSet.getObject("password"));
                System.out.println();
            }

        } catch (SQLException throwables) {
            throwables.printStackTrace();
        }finally {
            JDBC_utils.close(conn,st);
        }
    }
}
  • 使用JDBC_utils改進(jìn)編寫PreparedStatement的CURD:
package com.zzqsmile.lesson2;

import com.zzqsmile.lesson2.utils.JDBC_utils;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

public class Test_PreparedStatement {
    public static void main(String[] args) {
        try {
            //獲得數(shù)據(jù)庫連接
            Connection connection = JDBC_utils.getConnection();

            //編寫SQL     --增加
            String sql1 = "insert into user(username,password) values(?,?)";

            //獲得SQL預(yù)編譯執(zhí)行對象
            PreparedStatement preparedStatement1 = connection.prepareStatement(sql1);

            //賦值
            preparedStatement1.setString(1,"admin");
            preparedStatement1.setString(2,"admin");

            //執(zhí)行
            int i1 = preparedStatement1.executeUpdate();
            if (i1>0){
                System.out.println("添加成功");
                System.out.println();
            }

            //編寫SQL     --刪除
            String sql2 = "delete from user where id = ?";

            //獲得SQL預(yù)編譯執(zhí)行對象
            PreparedStatement preparedStatement2 = connection.prepareStatement(sql2);

            //賦值
            preparedStatement2.setString(1,"5");

            //執(zhí)行
            int i2 = preparedStatement2.executeUpdate();
            if (i2>0){
                System.out.println("刪除成功");
                System.out.println();
            }

            //編寫SQL     --更新
            String sql3 = "update user set password = '123321' where username = ?";

            //獲得SQL預(yù)編譯執(zhí)行對象
            PreparedStatement preparedStatement3 = connection.prepareStatement(sql3);

            //賦值
            preparedStatement3.setString(1,"admin");

            //執(zhí)行
            int i3 = preparedStatement3.executeUpdate();
            if (i3>0){
                System.out.println("修改成功");
                System.out.println();
            }

            //編寫SQL     --查詢
            String sql = "select * from user where username = ?";

            //獲得SQL預(yù)編譯執(zhí)行對象
            PreparedStatement preparedStatement = connection.prepareStatement(sql);

            //賦值
            preparedStatement.setString(1,"admin");

            //執(zhí)行
            ResultSet resultSet = preparedStatement.executeQuery();
            while (resultSet.next()){
                System.out.println("===========查詢結(jié)果============");
                System.out.println("id="+resultSet.getObject("id"));
                System.out.println("username="+resultSet.getObject("username"));
                System.out.println("password="+resultSet.getObject("password"));
                System.out.println();
            }

        } catch (SQLException throwables) {
            throwables.printStackTrace();
        }
    }
}
最后編輯于 ：
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 人面猴
    序言：七十年代末觅赊，一起剝皮案震驚了整個濱河市，隨后出現(xiàn)的幾起案子琼稻，更是在濱河造成了極大的恐慌吮螺，老刑警劉巖，帶你破解...
    沈念sama閱讀 206,214評論 6贊 481
  • 死咒
    序言：濱河連續(xù)發(fā)生了三起死亡事件帕翻，死亡現(xiàn)場離奇詭異鸠补，居然都是意外死亡，警方通過查閱死者的電腦和手機(jī)嘀掸，發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 88,307評論 2贊 382
  • 救了他兩次的神仙讓他今天三更去死
    文/潘曉璐 我一進(jìn)店門紫岩，熙熙樓的掌柜王于貴愁眉苦臉地迎上來，“玉大人睬塌，你說我怎么就攤上這事泉蝌。” “怎么了揩晴？”我有些...
    開封第一講書人閱讀 152,543評論 0贊 341
  • 道士緝兇錄：失蹤的賣姜人
    文/不壞的土叔 我叫張陵勋陪，是天一觀的道長。 經(jīng)常有香客問我硫兰，道長粥鞋，這世上最難降的妖魔是什么？ 我笑而不...
    開封第一講書人閱讀 55,221評論 1贊 279
  • ?港島之戀（遺憾婚禮）
    正文 為了忘掉前任瞄崇，我火速辦了婚禮呻粹，結(jié)果婚禮上壕曼，老公的妹妹穿的比我還像新娘。我一直安慰自己等浊，他們只是感情好腮郊，可當(dāng)我...
    茶點(diǎn)故事閱讀 64,224評論 5贊 371
  • 惡毒庶女頂嫁案：這布局不是一般人想出來的
    文/花漫 我一把揭開白布。 她就那樣靜靜地躺著筹燕，像睡著了一般轧飞。 火紅的嫁衣襯著肌膚如雪。 梳的紋絲不亂的頭發(fā)上撒踪，一...
    開封第一講書人閱讀 49,007評論 1贊 284
  • 城市分裂傳說
    那天过咬，我揣著相機(jī)與錄音，去河邊找鬼制妄。 笑死掸绞，一個胖子當(dāng)著我的面吹牛，可吹牛的內(nèi)容都是我干的耕捞。 我是一名探鬼主播衔掸，決...
    沈念sama閱讀 38,313評論 3贊 399
  • 雙鴛鴦連環(huán)套：你想象不到人心有多黑
    文/蒼蘭香墨 我猛地睜開眼，長吁一口氣：“原來是場噩夢啊……” “哼俺抽！你這毒婦竟也來了敞映？” 一聲冷哼從身側(cè)響起，我...
    開封第一講書人閱讀 36,956評論 0贊 259
  • 萬榮殺人案實(shí)錄
    序言：老撾萬榮一對情侶失蹤磷斧，失蹤者是張志新（化名）和其女友劉穎振愿，沒想到半個月后，有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體弛饭，經(jīng)...
    沈念sama閱讀 43,441評論 1贊 300
  • ?護(hù)林員之死
    正文 獨(dú)居荒郊野嶺守林人離奇死亡埃疫，尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 35,925評論 2贊 323
  • ?白月光啟示錄
    正文 我和宋清朗相戀三年，在試婚紗的時候發(fā)現(xiàn)自己被綠了孩哑。 大學(xué)時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
    茶點(diǎn)故事閱讀 38,018評論 1贊 333
  • 活死人
    序言：一個原本活蹦亂跳的男人離奇死亡翠桦，死狀恐怖横蜒，靈堂內(nèi)的尸體忽然破棺而出，到底是詐尸還是另有隱情销凑，我是刑警寧澤丛晌，帶...
    沈念sama閱讀 33,685評論 4贊 322
  • ?日本核電站爆炸內(nèi)幕
    正文 年R本政府宣布，位于F島的核電站斗幼，受9級特大地震影響澎蛛，放射性物質(zhì)發(fā)生泄漏。R本人自食惡果不足惜蜕窿，卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 39,234評論 3贊 307
  • 男人毒藥：我在死后第九天來索命
    文/蒙蒙 一谋逻、第九天 我趴在偏房一處隱蔽的房頂上張望呆馁。 院中可真熱鬧，春花似錦毁兆、人聲如沸浙滤。這莊子的主人今日做“春日...
    開封第一講書人閱讀 30,240評論 0贊 19
  • 一樁弒父案气堕，背后竟有這般陰謀
    文/蒼蘭香墨 我抬頭看了看天上的太陽纺腊。三九已至，卻和暖如春茎芭，著一層夾襖步出監(jiān)牢的瞬間揖膜，已是汗流浹背。 一陣腳步聲響...
    開封第一講書人閱讀 31,464評論 1贊 261
  • 情欲美人皮
    我被黑心中介騙來泰國打工梅桩， 沒想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留壹粟，地道東北人。 一個月前我還...
    沈念sama閱讀 45,467評論 2贊 352
  • 代替公主和親
    正文 我出身青樓摘投，卻偏偏與公主長得像煮寡，于是被迫代替她去往敵國和親。 傳聞我的和親對象是個殘疾皇子犀呼，可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 42,762評論 2贊 345

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

  • 1. 下載 mysql-connector-java-8.0.11.jar 版本參考：https://dev.my...
    頂寶麻麻閱讀 212評論 0贊 0
  • 一幸撕、前期準(zhǔn)備工作 主要是下載jaridea 在mave的pox中eclipse1、在根目錄下新建一個lib文件夾?...
    唯老閱讀 431評論 1贊 0
  • 使用環(huán)境說明 環(huán)境：Centos7, jdk8, mysql5.7外臂，Ambari 2.7.4.0主節(jié)點(diǎn)：ambma...
    阿湯哥_8d27閱讀 910評論 0贊 0
  • 前言 與DataStream同樣坐儿，官方在Flink SQL上也提供了很多連接器，今天來學(xué)習(xí)總結(jié)一下JDBC連接器 ...
    倆只猴閱讀 5,202評論 0贊 0
  • 十宋光、JDBC（重點(diǎn)） 1.數(shù)據(jù)庫驅(qū)動 驅(qū)動：聲卡貌矿、顯卡以及數(shù)據(jù)庫等都需要驅(qū)動。 程序會通過數(shù)據(jù)庫驅(qū)動罪佳，和數(shù)據(jù)庫打交...
    Ping開源閱讀 250評論 0贊 2