JDBC快速入門

来源:https://www.cnblogs.com/mzq-/archive/2020/07/16/13284943.html
-Advertisement-
Play Games

JDBC快速入門 詳解 １.０DriverManager 功能1 功能2 2.0 connection對象 3.0 statement對象 4.0 ResultSet 遍歷結果集的一個案例 import java.sql.*; public class DQLtest { public static ...


JDBC快速入門

 

詳解

１.０DriverManager

功能1

 

 

 

功能2

2.0 connection對象

 

3.0 statement對象

 

 

4.0 ResultSet

遍歷結果集的一個案例

 

import java.sql.*;

public class DQLtest {
    public static void main(String[] args)  {
        //註冊驅動
        Connection connection=null;
        Statement statement=null;
        ResultSet resultSet =null;
        try{
            Class.forName("com.mysql.cj.jdbc.Driver");
            //定義一個SQL語句
            String sql="select * from student";
            //資料庫連接對象 此處url要在原來資料庫後加上 "?serverTimezone=GMT%2B8&useSSL=false"
            //因為我導入的jar包為最新版本 要添加ssl連接狀態
            connection = DriverManager.getConnection("jdbc:mysql:///db2" +
                    "?serverTimezone=GMT%2B8&useSSL=false", "root", "root");
            //執行SQL的對象
            statement = connection.createStatement();
            //獲取結果集對象
            resultSet = statement.executeQuery(sql);
            while(resultSet.next())//next方法判斷游標是否位於最後一行，是則返回false 否則返回true
            {
                int id = resultSet.getInt("ID");
                int age= resultSet.getInt("age");
                String name = resultSet.getString("name");
                String cls = resultSet.getString("class");
                System.out.println(id+" "+age+" "+name+" "+cls);
            }

        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        }finally {
            try {
                connection.close();
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            }
            try {
                statement.close();
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            }
            try {
                resultSet.close();
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            }
        }

    }
}

　　

 

列印結果：

1 18 lisa 191
2 19 JK 192
3 18 rose 191
4 19 V 192
5 20 suga 181
6 21 jimin 182

 

JDBC工具類的創建以及使用

1.0 配置文件

drive=com.mysql.cj.jdbc.Driver
url=jdbc:mysql:///db2?serverTimezone=GMT%2B8&useSSL=false
user=root
password=root

2.0 JDBCutil的創建

import java.io.FileReader;
import java.io.IOException;
import java.net.URL;
import java.sql.*;
import java.util.Properties;

public class JDBCutil {
    /*
    * 1.靜態代碼塊中 註冊驅動、資料庫連接對象 url user password
    * 2.釋放資源
    * */
    public static String drive;
    public static String url;
    public static String user;
    public static String password;
    static {
        Properties properties = new Properties();
        //獲取src目錄下的文件方式->類載入器 Classloader
        //先獲取位元組碼文件
        ClassLoader classLoader = JDBCutil.class.getClassLoader();
        URL resource = classLoader.getResource("jdbc.properties");
        //URL 統一資源定位符 獲取絕對路徑
        String path = resource.getPath();
        try {
            properties.load(new FileReader(path));
        } catch (IOException e) {
            e.printStackTrace();
        }
        drive = properties.getProperty("drive");
         url = properties.getProperty("url");
         user = properties.getProperty("user");
         password = properties.getProperty("password");

    }
    public static Connection getConnection() throws SQLException {

        return DriverManager.getConnection(url,user,password);
    }

    public static void close(Connection conn, Statement stat)
    {
        try {
            conn.close();
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        }
        try {
            stat.close();
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        }
    }
    //重載
    public static void close(Connection conn, Statement stat, ResultSet res)
    {
        try {
            conn.close();
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        }
        try {
            stat.close();
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        }
        try {
            res.close();
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        }
    }
}

 

對案例進行優化 使用JDBCutil類

import java.sql.*;

public class DQLtest {
    public static void main(String[] args)  {
        //註冊驅動
        Connection connection=null;
        Statement statement=null;
        ResultSet resultSet =null;
        try{
            //Class.forName("com.mysql.cj.jdbc.Driver");
            //定義一個SQL語句
            String sql="select * from student";
 
           // connection = DriverManager.getConnection("jdbc:mysql:///db2" +
           //"?serverTimezone=GMT%2B8&useSSL=false", "root", "root");
           connection = JDBCutil.getConnection();

            //執行SQL的對象
           statement= connection.createStatement();
            //獲取結果集對象
           resultSet = statement.executeQuery(sql);
            while(resultSet.next())//next方法判斷游標是否位於最後一行，是則返回false 否則返回true
            {
                int id = resultSet.getInt("ID");
                int age= resultSet.getInt("age");
                String name = resultSet.getString("name");
                String cls = resultSet.getString("class");
                System.out.println(id+" "+age+" "+name+" "+cls);
            }

        } catch (SQLException throwables) {
            throwables.printStackTrace();
        }
        finally {
            JDBCutil.close(connection,statement,resultSet);
        }
    }
}

　　

頁面登錄案例

　PreparedStatement　

 

import java.sql.*;
import java.util.Scanner;

public class Usertest {
    public static void main(String[] args) {
        Scanner input = new Scanner(System.in);
        System.out.println("請輸入您的姓名：");
        String username=input.next();
        System.out.println("請輸入您的密碼：");
        String password=input.next();
        Connection conn=null;
        PreparedStatement prep =null;
        ResultSet set=null;
        try{
            conn = JDBCutil.getConnection();
            //String sql="SELECT *FROM USER WHERE NAME='"+username+"'AND PASSWORD='"+password+"'";
            String sql="SELECT *FROM USER WHERE NAME=? AND PASSWORD=?";
            prep = conn.prepareStatement(sql);
            //給？賦值
            prep.setString(1,username);
            prep.setString(2,password);
            ResultSet resultSet = prep.executeQuery();
           if(resultSet.next())
           {
               System.out.println("登錄成功！");
           }
           else {
               System.out.println("登錄失敗！");
           }
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        }finally {
            JDBCutil.close(conn,prep,set);
        }

    }
}

 

　　

 JDBC管理事務

 

資料庫連接池

1.0 介紹

 

重點介紹druid 

 

 

下麵就建立一個druid工具類來使用（mysql-connector-java-8.0.11.jar）（druid-1.1.21.jar）

定義配置文件druid.properties

driverClassName=com.mysql.cj.jdbc.Driver
url=jdbc:mysql:///db2?serverTimezone=GMT%2B8&useSSL=false
username=root
password=root
#初始化連接數量
initialSize=5
#最大連接數
maxActive=10
#最大等待時間
maxWait=3000

　

定義一個工具類

package utils;

import com.alibaba.druid.pool.DruidDataSourceFactory;

import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;

public class Druidutil {
    public static DataSource ds;
    //導入jar包
    //定義配置文件
    //載入配置文件
    static{

        try {
            Properties prop = new Properties();
            prop.load(Druidutil.class.getClassLoader().getResourceAsStream("druid.properties"));
            ds = DruidDataSourceFactory.createDataSource(prop);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    //獲取連接對象
    public static Connection getConnection() throws SQLException {
        return ds.getConnection();
    }

    //釋放資源

    public static void close(Statement stat,Connection conn)
    {
     close(null,stat,conn);
    }


    public static void close(ResultSet res,Statement stat, Connection conn)
    {
        if(res!=null)
        {
            try {
                res.close();
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            }
        }
        if(stat!=null)
        {
            try {
                stat.close();
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            }
        }
        if(conn!=null)
        {
            try {
                conn.close();
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            }
        }
    }

    //獲取連接池
    public static DataSource getDataSource()
    {
        return ds;
    }
}

 

定義一個測試類來測試一下這個工具類　

import utils.Druidutil;

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

public class Druidtest {
    public static void main(String[] args) {
        //需求：給db2中的表 student 添加一條數據
        Connection conn=null;
        PreparedStatement prep=null;
        try {
            //1.獲取連接
            conn = Druidutil.getConnection();
            //2.定義sql
            String sql="INSERT INTO student VALUES(NULL,?,?,?)";//使用prepareStatement
            //3.獲取prepareStatement對象
            prep = conn.prepareStatement(sql);
            prep.setInt(1,18);
            prep.setString(2,"Jennie");
            prep.setString(3,"191");
            //4.執行sql
            int result = prep.executeUpdate();
            //列印結果
            System.out.println(result);
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        }finally{
            Druidutil.close(prep,conn);
        }

    }
}

　

（添加成功）

 

為了簡化JDBC的使用 我們引入一個 Spring JDBC (JDBCTemplate)

 

1.DML語句

 

import org.springframework.jdbc.core.JdbcTemplate;
import utils.Druidutil;

public class SpringJDBC {
    private static JdbcTemplate template;
    public static void main(String[] args) {

        //執行DML語句
        //導入jar包 獲取JDBCtemplate
        template = new JdbcTemplate(Druidutil.getDataSource());
        //test1();//修改操作
        //test2();//添加操作
        //test3();//刪除操作
    }

    private static void test3() {
        String sql="delete from user where id=?";
        int update = template.update(sql, 3);
        System.out.println(update);
    }

    private static void test2() {
        String sql="insert into user (id,name,password) values (?,?,?)";
        int update = template.update(sql, 4, "bts", "613");
        System.out.println(update);
    }

    private static void test1()
    {
        //定義sql語句
        String sql="update user set password='121' where id=1";
        //執行sql
        int update = template.update(sql);
        System.out.println(update);
    }
}

 

2.DQL語句　　

 

import org.springframework.jdbc.core.BeanPropertyRowMapper;
import org.springframework.jdbc.core.JdbcTemplate;
import utils.Druidutil;

import java.util.List;
import java.util.Map;

public class SpringJDBC {
    private static JdbcTemplate template;

    public static void main(String[] args) {

        //執行DQL語句
        //導入jar包 獲取JDBCtemplate
        template = new JdbcTemplate(Druidutil.getDataSource());
        //test1();//查詢一條記錄
        //test2();//查詢多條條記錄
        //test3();//將每條數據分裝為emp對象
         //test4();//查詢總記錄數
    }

    private static void test4() {
        String sql="select count(*) from user";
        Long aLong = template.queryForObject(sql, Long.class);
        System.out.println(aLong);
    }

    private static void test3() {
        String sql="select * from user";
        List<emp> query = template.query(sql, new BeanPropertyRowMapper<emp>(emp.class));
        for (emp emp : query) {
            System.out.println(emp);
        }
    }

    private static void test2() {
        String sql="select * from user";
        List<Map<String, Object>> list = template.queryForList(sql);
        for (Map<String, Object> map : list) {
            System.out.println(map);
        }
    }

    private static void test1() {
        String sql="select * from user where id=?";
        Map<String, Object> map = template.queryForMap(sql, 3);
        System.out.println(map);
    }
}

 

　　

 


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 列出Windows所有設備驅動名
    ###Windows驅動名列印 #include <stdio.h> #include <Psapi.h> #include <Shlwapi.h> #include <Windows.h> #pragma comment(lib, "psapi.lib") #pragma comment(lib, ...
  • Java應用伺服器之tomcat基礎配置（一）
    所謂部署就是把webapp的源文件放置於目標目錄（網頁程式文件存放目錄，類似httpd中的documentroot指定的目錄），然後配置tomcat伺服器能夠基於web.xml和context.xml文件中定義的路徑來訪問webapp；然後將其特有的類和依賴的類通過類載入器（class loade... ...
  • 校驗文件MD5_SHA1_SHA256值
    win中查看MD5值：certutil -hashfile 文件名 MD5查看 SHA1certutil -hashfile 文件名 SHA1查看SHA256certutil -hashfile 文件名 SHA256linux中 md5sum 文件名 ...
  • kafka之消息隊列
    大數據工具 kafka 學習 之前需要先瞭解隊列的相關知識 瞭解萬隊列就知道kafka的用處 之後再詳細瞭解kafka的具體知識和操作 ...
  • MySQL學習筆記（19）：優化資料庫對象
    本文更新於2019-08-18，使用MySQL 5.7，操作系統為Deepin 15.4。 一旦資料庫對象設計完畢並投入使用，再進行修改就比較麻煩。 優化表的數據類型 select_statement PROCEDURE ANALYSE([max_elements[, max_memory]]) 對 ...
  • 比較全的大數據技術組件整理以及相關理論論文整理
    框架 Apache Hadoop：分散式處理架構，結合了 MapReduce(並行處理)、YARN(作業調度)和HDFS(分散式文件系統); Tigon：高吞吐量實時流處理框架。 分散式編程 AddThis Hydra ：最初在AddThis上開發的分散式數據處理和存儲系統; AMPLab SIMR ...
  • DataStream API（一）
    DataStream API（一） 在瞭解DataStream API之前我們先來瞭解一下Flink API的構成。Flink API是分層的。由最底層的Stateful Stream Process到最頂層的SQL分為四層。如下圖： DataStream API 顧名思義，就是DataStream ...
  • java大數據最全課程學習筆記(3)--HDFS 簡介及操作
    目前CSDN,博客園,簡書同步發表中,更多精彩歡迎訪問我的gitee pages HDFS 簡介及操作 HDFS概述 HDFS產出背景及定義 HDFS優缺點 HDFS組成架構 HDFS文件塊大小（重點） 塊在傳輸時，每64K還需要校驗一次，因此塊大小，必須為2的n次方，最接近100M的就是128M！ ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類