?大家可以關注一下我的博客 ?我的博客所有隨筆都是我從基礎開始學習java的所有知識點

1.?Jdbc概述

問題：實際開發中，不可能用工具或者命令行操作數據庫，數據庫表中的數據最終要使用Java程序來操作,那么Java中如何操作數據庫中的數據呢？

?

答 ： 在Java語言中，有一個專門連接數據庫的規范（JDBC），專門負責連接數據庫進行數據操作的規范

?

JDBC只是SUN編寫的一堆接口（規范的體現），SUN公司自己并沒有實現

?

?

問題 ： 為什么SUN只定義一個JDBC規范，而不實現呢？

?

答 ： 因為市面上的數據庫很多，每個數據庫內部接口不會向外暴露，而且即便是暴露讓SUN去實現，市面上很多數據庫全部要SUN來實現不現實

?

實際中哪個數據庫需要支持JAVA語言，就需要自己實現Java的JDBC規范，因為實現了JDBC很多接口，那么就會有很多實現類，而很多實現類在java中會使用一個專門的包封裝起來，叫做jar包（在JDBC中叫做驅動包），各大數據庫產商實現JDBC規范以后都會把他們jar包放在官網上以供開發者下載使用

?

?

?

JDBC：(Java DataBase Connectivity):

是一種用于執行SQL語句的Java API，可以為多種關系數據庫提供統一訪問，它由一組用Java語言編寫的類和接口組成。

JDBC規范對應的api包

?

?

?

案例使用JDBC操作MySQL數據庫：

1.?創建普通java項目

?

2.?在項目下面新建一個lib目錄（new鍵--》folder）

?

3.?將MySQL驅動包拷貝到項目中并添加依賴（build path--》add to build path）

?

?

4. 開始寫代碼

DDL創建表：

package jdbc; //連接使用oracle數據庫import java.sql.Connection; import java.sql.DriverManager; import java.sql.Statement;import org.junit.Test;public class Test01 {/*** Java中單元測試方法的 創建* * 在空白處 寫 test，使用快捷鍵 alt+/ 提示，選擇 junit4* 會自動補全 junit4單元測試的方法* 在方法上面有一個注解，默認報錯的* 因為：單元測試是一個框架，默認eclipse以及集成了，用戶把鼠標放置在 注解上面，按提示導入junit4 依賴即可* 單元測試方法和main方法區別* junit單元測試方法在一個類中可以有多個方法，每個一個方法可以獨立運行* main 主方法一個類中只能有一個方法，不太方便多個功能的測試* * 單元測試方法的運行，光標放置在單元測試方法上面，點擊數據右鍵 【run as ->junit test】* 綠條：表示成功* 紅條：表示程序可能異常*/@Test public void testName1() throws Exception {//創建表操作:要執行的sql代碼String sql="create table t_student(sid number(4) constraint pk_sid primary key,name varchar2(20))";//1，加載注冊驅動Class.forName("oracle.jdbc.OracleDriver");/*加載注冊驅動.(mysql的)就是把驅動中的Driver字節碼加載到JVM中.Class.forName("com.mysql.jdbc.Driver");為什么這句話就可以加載注冊驅動?第一步:把com.mysql.jdbc.Driver.class這份字節碼加載到JVM中.第二步:當一份字節碼被加載進JVM,馬上就會執行該字節碼中的靜態代碼塊.第三步:該靜態代碼中,就在完成,先創建驅動對象,再注冊.* */ //2，獲取數據庫連接（"jdbc:oracle:thin:@127.0.0.1:1521:數據庫名","賬號","密碼"）Connection conn= DriverManager.getConnection("jdbc:oracle:thin:@127.0.0.1:1521:orcl","scott","tiger");/*jdbc:mysql://localhost:3306/dbNamejdbc:mysql:// ：連接MySQL數據庫的協議，不同數據庫協議不一樣localhost:3306 ：數據庫軟件的主機和端口dbName ： 具體要連接數據庫驗證已經獲取連接:可以在MySQL控制臺,使用命令:show processlist; 查看MySQL運行進程.* *///3，創建語句對象（用于執行SQL語句的對象）Statement c = conn.createStatement();//4， 執行SQL語句 c.executeUpdate(sql);//5，釋放資源(先開后關) c.close();conn.close();} }

?

package jdbc; //連接使用mysql數據庫import java.sql.Connection; import java.sql.DriverManager; import java.sql.Statement;import org.junit.Test;public class Test02 { @Test public void testName1() throws Exception {//創建一個學生表//創建表的mysql操作：要執行的sql代碼 String sql="create table t_student(id int primary key auto_increment,name varchar(50),age int)";//1.加載注冊驅動Class.forName("com.mysql.jdbc.Driver");//2.獲取數據庫連接對象Connection conn= DriverManager.getConnection("jdbc:mysql://localhost:3306/lin01", "root", "root");//3.創建語句對象（用于執行SQL語句）Statement st=conn.createStatement();//4.執行SQL語句 st.executeUpdate(sql);//5.釋放資源(先開后關) st.close();conn.close();} }

DML：表的增刪改：

package jdbc; //連接使用mysql數據庫import static org.junit.Assert.*;import java.sql.Connection; import java.sql.DriverManager; import java.sql.Statement;import org.junit.Test;public class Test02 { @Test public void testName1() throws Exception {//DML 增://創建表的mysql操作：要執行的sql代碼 String sql=("insert into t_student(name,age) values ('張三',20)");//1.加載注冊驅動Class.forName("com.mysql.jdbc.Driver");//2.獲取數據庫連接對象Connection conn= DriverManager.getConnection("jdbc:mysql://localhost:3306/lin01", "root", "root"); //3.創建語句對象（用于執行SQL語句）Statement st=conn.createStatement();//4.執行SQL語句 st.executeUpdate(sql);//5.釋放資源(先開后關) st.close();conn.close();}public void testName2() throws Exception{//DML 刪: String sql=("delete from t_student where id=2");Class.forName("com.mysql.jdbc.Driver");Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/lin01", "root", "root");Statement st=conn.createStatement();st.executeUpdate(sql);st.close();conn.close();} @Test public void testName3() throws Exception {//DML 改:String st="update t_student set name='李四',age=15 where id=1";Class.forName("com.mysql.jdbc.Driver");Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/lin01", "root", "root");Statement cr= conn.createStatement();cr.executeUpdate(st);cr.close();conn.close();}}

?

DQL表的查詢：

package jdbc; //學生類 public class Student {private int id ;private String name;private Integer age;public int getId() {return id; }public void setId(int id) {this.id = id; }public String getName() {return name; }public void setName(String name) {this.name = name; }public Integer getAge() {return age; }public void setAge(Integer age) {this.age = age; }public Student(int id, String name, Integer age) {super();this.id = id;this.name = name;this.age = age; }public Student() {super(); }@Override public String toString() {return "Student [id=" + id + ", name=" + name + ", age=" + age + "]"; }}

?

package jdbc; //連接使用mysql數據庫import static org.junit.Assert.*;import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.Statement; import java.util.ArrayList; import java.util.List;import org.junit.Test;public class Test02 { @Test public void testName1() throws Exception {//多行查詢String str="select * from t_student";Class.forName("com.mysql.jdbc.Driver");Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/lin01", "root", "root");Statement cr = conn.createStatement();ResultSet ex = cr.executeQuery(str);//創建一個學生類//申明一個list集合，封裝一個個學生對象List<Student> stu = new ArrayList<Student>();while(ex.next()){//1.通過列的位置獲取對應的數據 從1開始(如果不知道類型就用Object)Object id = ex.getObject(1);Object name = ex.getObject(2);Object age = ex.getObject(3);System.out.println(id+"\t"+name+"\t"+age);cr.close();conn.close();//2.通過列的名稱獲取對應的數據((知道類型就用相應的類型)int id1 = ex.getInt("id");String name1 = ex.getString("name");int age1 = ex.getInt("age");System.out.println(id1+"\t"+name1+"\t"+age1);cr.close();conn.close();//3.將每一行數據封裝成一個個Student對象快速生成變量，光標放在 代碼末尾， ctrl+1 提示int id2 = ex.getInt("id");String name2 = ex.getString("name");int age2 = ex.getInt("age");Student student = new Student(id2,name2,age2);stu.add(student);}for (Student student : stu){System.out.println(student);}ex.close();cr.close();conn.close();}} package jdbc; //連接使用mysql數據庫import static org.junit.Assert.*;import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.Statement; import java.util.ArrayList; import java.util.List;import org.junit.Test;public class Test02 { @Test public void testName1() throws Exception {//單行查詢String str="select * from t_student where id=7";Class.forName("com.mysql.jdbc.Driver");Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/lin01", "root", "root");Statement cr = conn.createStatement();ResultSet ex = cr.executeQuery(str);List<Student> stu=new ArrayList<Student>();if(ex.next()){int id = ex.getInt("id");String name = ex.getString("name");int age = ex.getInt("age");Student stud=new Student(id,name,age);stu.add(stud);}System.out.println(stu); }}

?

?

預編譯語句對象PreparedStatment

問題 ： 我們有了Statment對象可以執行SQL，為什么還要使用PreparedStatment？

?

優勢

SQL語句結構清晰，參數的設置和SQL語句分離

性能更高

防止SQL注入

Statement: 表示靜態SQL語句對象.

PreparedStatement:Statement的子接口,表示預編譯SQL語句對象. 通過占位符(?)來拼SQL.?

?

?

package jdbc; //連接使用mysql數據庫import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement;import org.junit.Test;public class Test02 { @Test public void testName1() throws Exception {//使用預編譯語句對象執行DML操作//模板sql語句(增加數據)String sql="insert into t_student(name,age) values(?,?) ";/**刪除：String sql = "delete from t_student where id = ?";* 修改：String sql = "update t_student set name = ?,age=? where id = ?";*/// 1.加載注冊驅動Class.forName("com.mysql.jdbc.Driver");// 2.獲取數據庫連接對象Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/lin01", "root", "root");// 3.創建預編譯語句對象PreparedStatement pr = conn.prepareStatement(sql);//3.1設置預編譯語句對象占位符對應的參數值pr.setString(1, "maxysh");pr.setInt(2, 99);// 4.執行SQL語句 (注意：方法不能帶sql參數) pr.executeUpdate();// 5.釋放資源 pr.close();conn.close();} }

?

?

package jdbc; //連接使用mysql數據庫import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement;import java.sql.ResultSet; import java.util.ArrayList; import java.util.List;import org.junit.Test;public class Test02 { @Test public void testName1() throws Exception {//使用預編譯語句對象執行DML操作//模板sql語句(查詢數據)String sql="select * from t_student ";// 1.加載注冊驅動Class.forName("com.mysql.jdbc.Driver");// 2.獲取數據庫連接對象Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/lin01", "root", "root");// 3.創建預編譯語句對象PreparedStatement pr = conn.prepareStatement(sql);// 4.執行SQL語句 (注意：方法不能帶sql參數)ResultSet ex = pr.executeQuery();//申明一個list集合，封裝一個個學生對象List<Student> students = new ArrayList<Student>();while(ex.next()){int id = ex.getInt("id");String name = ex.getString("name");int age = ex.getInt("age");Student stu=new Student(id,name,age);students.add(stu);}System.out.println(students);// 5.釋放資源 ex.close();pr.close();conn.close();}}

?

?

?JavaWeb開發的分層設計-三層架構

?DAO層設計

?

實際開發中，JavaWeb開發代碼一般分為三層,分層結構是JavaWeb開發中的一種設計思想，這樣會讓我們開發層次分明，每一層只要完成對應的功能即可，使得項目便于開發和維護

?

1 . Web層/表現層 ： 主要接受前臺瀏覽器用戶的參數，給瀏覽器響應數據等等

2.Service層/業務成/服務層：主要處理業務功能，日志，權限，事物，等等

3.DAO層/持久層 ：專門負責和數據庫交互，數據處理相關代碼

?

DAO ： Data Access Object 數據訪問對象

?

實際開發中 ： 用戶請求到-Web層--->Service層-->DAO層

?

?使用DAO以后代碼的以及包的設計結構

?

開發中如果使用的分層，編寫的包和類名接口名等等都是有固定規則，不能隨便瞎寫

?

?DAO層接口包命名

?

公司域名倒寫+項目名稱/模塊名稱+dao ? ??如 ： cn.sxt.crm.dao

?DAO層實現類包命名

?

公司域名倒寫+項目名稱/模塊名稱+dao+impl ?如 ： cn.sxt.crm.dao.impl

?DAO層操作對應表的接口命名

對應表的名稱 +?Dao/DAO?如 ： StudentDao/DAO , TeacherDao/DAO

DAO層操作對應表的實現類命名

?

對應表的名稱 +?Dao/DAOImpl ??如 ： StudentDaoImpl/DAOImpl , TeacherDaoImpl/DAOImpl

?數據表對應的Java類domain/pojo包命名

?

POJO（Plain Ordinary Java Object）簡單的Java對象
domian ： 域對象

?

公司域名倒寫+項目名稱/模塊名稱+domain/pojo ??如 ： cn.sxt.crm.domain

對應的測試包命名

公司域名倒寫+項目名稱/模塊名稱+test ? ?如 ： cn.sxt.crm.test

項目的工具類包命名

公司域名倒寫+項目名稱/模塊名稱+util/utils ??如 ： cn.sxt.crm.util/utils

?

package cn.sxt.crm.test;import java.io.InputStream; import java.util.Properties;import org.junit.Test; /*new --->file* ClassLoader 類加載器* ClassLoader ：可以從項目的類路徑下面讀取對應的配置文件返回一個輸入流* ClassLoader 在程序運行的時候JVM已經為每一個項目都創建了一個，我們開發者只需要獲取即可* 獲取類加載器方式* 1、使用當前線程* ClassLoader classLoader = Thread.currentThread().getContextClassLoader();* 2、通過某一類的字節碼實例也可以獲取* ClassLoader classLoader = PropertiesTest.class.getClassLoader();*/ //ClassLoader classLoader = Thread.currentThread().getContextClassLoader(); //使用類加載器獲取項目 類路徑下面的文件 //InputStream inputStream = classLoader.getResourceAsStream("db.properties");/* * Properties 是Map集合下面的一個 專門用于讀取配置文件的對象 * 可以讀取當前類路徑下面的 xxx.properites類型的配置文件 * * xxx.properites的內容必須是key=value 鍵值對的數據 */public class PropertiesTest {@Testpublic void test1() throws Exception {//1.使用當前線程可以獲取類加載器ClassLoader classLoader = Thread.currentThread().getContextClassLoader();//2.使用類加載器讀取db.properties配置文件InputStream in = classLoader.getResourceAsStream("dp.properties");//3.創建Properties對象（專門讀取xxx.properties配置文件中的內容，本質就是Map集合，數據結構key--->value）Properties p = new Properties();//4.加載配置文件 p.load(in);System.out.println(p);//5.獲取單個指定key的值String str1=p.getProperty("str1");String str2=p.getProperty("str2");String str3=p.getProperty("str3");String str4=p.getProperty("str4");System.out.println(str1);}}

?

package cn.sxt.crm.test;import static org.junit.Assert.*;import java.io.InputStream; import java.sql.Connection; import java.util.Properties;import javax.sql.DataSource;import org.junit.Test;import com.alibaba.druid.pool.DruidDataSource; import com.alibaba.druid.pool.DruidDataSourceFactory;//Druid連接池的使用 public class DateSourceTest { @Test//直接手動創建連接池對象 public void testName1() throws Exception {//1.創建druid連接池對象DruidDataSource ds = new DruidDataSource();ds.setDriverClassName("com.mysql.jdbc.Driver");ds.setUrl("jdbc:mysql://localhost:3306/lin01");ds.setUsername("root");ds.setPassword("root");//設置最大連接數ds.setMaxActive(10);Connection conn = ds.getConnection();System.out.println(conn); } //使用Druid工廠對象讀取配置文件來創建連接池對象 @Test public void testName() throws Exception {//獲取類加載器ClassLoader classLoader=Thread.currentThread().getContextClassLoader();InputStream in=classLoader.getResourceAsStream("dp.properties");Properties properties=new Properties();properties.load(in);//使用工廠創建連接池對象DataSource ds=DruidDataSourceFactory.createDataSource(properties );Connection conn = ds.getConnection();System.out.println(conn);} } str1=com.mysql.jdbc.Driver str2=jdbc:mysql://localhost:3306/lin01 str3=root str4=root maxActive=10

-----------------------------------------------------------------------------------------

------------------------------------------------------------------------------------------------------

package cn.sxt.crm.dao;import java.util.List;import cn.sxt.crm.pojo.Student;public interface StudentDao {/*** 插入方法* @param stu 封裝有學生信息的Student對象(數據庫自增id，開發者不需要傳id)* @return 受影響的行數*/ int insert(Student stu);//增方法/*** 根據主鍵刪除數據* @param id 主鍵id的值* @return 受影響的行數*/ int delete(Integer id);/*** 修改操作* @param stu 帶有id值的Student對象（修改根據主鍵id值修改）* @return 受影響的行數*/int update(Student stu);/*** 單行查詢* @param id 主鍵id* @return 單行數據封裝的對象*/ Student selectByPrimaryKey(Integer id);/*** 多行查詢* @return 封裝有一個個Student對象的集合*/List<Student> selectList();} package cn.sxt.crm.dao.impl;import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.util.ArrayList; import java.util.List; import cn.sxt.crm.dao.StudentDao; import cn.sxt.crm.pojo.Student; import cn.sxt.crm.util.utils;public class StudentDaoImpl implements StudentDao {@Overridepublic int insert(Student stu) {String sql="insert into t_student(name,age)values(?,?)";Connection conn=null;PreparedStatement pr=null;try {conn =utils.getConnection();pr = conn.prepareStatement(sql);pr.setString(1,stu.getName());pr.setInt(2, stu.getAge());int row=pr.executeUpdate();return row;} catch (Exception e) {e.printStackTrace();}finally{utils.close(conn, pr, null);}return 0;}@Overridepublic int delete(Integer id) {String sql="delete from t_student where id=?";Connection conn=null;PreparedStatement pr=null;try {conn = utils.getConnection();pr = conn.prepareStatement(sql);pr.setInt(1,id);int row=pr.executeUpdate();return row;} catch (Exception e) {e.printStackTrace();}finally{utils.close(conn, pr, null);}return 0;}@Overridepublic int update(Student stu) {String sql="update t_student set name=?,age=? where id=?";Connection conn=null;PreparedStatement pr=null;try {conn =utils.getConnection();pr = conn.prepareStatement(sql);pr.setString(1,stu.getName());pr.setInt(2, stu.getAge());pr.setInt(3, stu.getId());int row=pr.executeUpdate();return row;} catch (Exception e) {e.printStackTrace();}finally{utils.close(conn, pr, null);}return 0;}@Overridepublic Student selectByPrimaryKey(Integer id) {String sql="select * from t_student where id=?";Connection conn=null;PreparedStatement pr=null;ResultSet ex=null;try {conn = utils.getConnection();pr = conn.prepareStatement(sql);pr.setInt(1,id);ex = pr.executeQuery();while(ex.next()){String name=ex.getString("name");int age=ex.getInt("age");// 封裝Student對象Student stu = new Student(id, name, age);//返回Student對象return stu;}} catch (Exception e) {e.printStackTrace();}finally{utils.close(conn, pr, ex);}return null;}@Overridepublic List<Student> selectList() {List<Student> student= new ArrayList<Student>();String sql="select * from t_student";Connection conn=null;PreparedStatement pr=null;ResultSet ex=null;try {conn =utils.getConnection();pr = conn.prepareStatement(sql);ex = pr.executeQuery();while(ex.next()){int id=ex.getInt("id");String name=ex.getString("name");int age=ex.getInt("age");// 封裝Student對象Student stu = new Student(id, name, age);// 學生對象添加到集合中 student.add(stu);}} catch (Exception e) {e.printStackTrace();}finally{utils.close(conn, pr, ex);}return student;}} package cn.sxt.crm.pojo;public class Student { private Integer id; private String name; private Integer age; public Integer getId() {return id; } public void setId(Integer id) {this.id = id; } public String getName() {return name; } public void setName(String name) {this.name = name; } public Integer getAge() {return age; } public void setAge(Integer age) {this.age = age; } public Student(Integer id, String name, Integer age) {super();this.id = id;this.name = name;this.age = age; } public Student() {super(); } @Override public String toString() {return "Student [id=" + id + ", name=" + name + ", age=" + age + "]"; }} package cn.sxt.crm.test;import java.util.List;import org.junit.Test;import cn.sxt.crm.dao.StudentDao; import cn.sxt.crm.dao.impl.StudentDaoImpl; import cn.sxt.crm.pojo.Student;public class StudentDaoTest {private StudentDao dao=new StudentDaoImpl();@Testpublic void testInsert() {Student stu=new Student(null, "葉孤城", 30);int row=dao.insert(stu);System.out.println(row);}@Testpublic void testDelete() {int row=dao.delete(10);System.out.println(row);}@Testpublic void testUpdate() {Student stu=new Student(9, "葉孤城", 30);int row=dao.update(stu);System.out.println(row);}@Testpublic void testSelectByPrimaryKey() {Student stu = dao.selectByPrimaryKey(3);System.out.println(stu);}@Testpublic void testSelectList() {List<Student> students = dao.selectList();System.out.println(students);}} package cn.sxt.crm.util;import java.io.InputStream; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.util.Properties;import javax.sql.DataSource;import com.alibaba.druid.pool.DruidDataSourceFactory;public class utils {// 創建讀取配置文件的配置對象private static Properties p=new Properties(); //連接池對象private static DataSource da;static {try {ClassLoader classLoader=Thread.currentThread().getContextClassLoader();InputStream inputStream=classLoader.getResourceAsStream("dp.properties");p.load(inputStream);//創建連接池對象da= DruidDataSourceFactory.createDataSource(p);} catch (Exception e) {e.printStackTrace();}}public static Connection getConnection(){try {Connection conn = da.getConnection();return conn;} catch (Exception e) {throw new RuntimeException("連接失敗");}}public static void close(Connection conn,PreparedStatement pr,ResultSet ex){try {if(ex!=null){ex.close();}} catch (SQLException e1) {e1.printStackTrace();}finally{try {if(pr!=null){pr.close();}} catch (SQLException e) {e.printStackTrace();}finally{try {if(conn!=null){conn.close();}} catch (SQLException e) {e.printStackTrace();} }}}}

driverClassName=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/lin01
username=root
password=root
maxActive=1

配置必須按規定命名，

轉載于:https://www.cnblogs.com/406070989senlin/p/10887305.html

總結

以上是生活随笔為你收集整理的JDBC , 使用java来控制mysql。JavaWeb开发的分层设计-三层架：DAO层设计，连接池使用，类加载使用，配置...的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。