JDBC封裝-Java（新手）

 

 

JDBC的封裝，自己總結的自己總結的自己總結的

 

---

 

dao （代碼分層）命名規范：

　　　　1、com.XXX.dao 　　 存放dao相關的類型 例如 StudentDAOImpl 處理 數據庫的鏈接 存取數據

　　　　2、com.XXX.servlet    存放servlet相關的類 例如：StudentServlet 處理 與瀏覽器交互的類

　　　　3、com.XXX.entity     存放實體類 例如 Student 接受數據庫對象模型

　　　　4、com.XXX.util         存放工具類 例如 DBUtil

 

---

操作步驟： 

---

首先，創建一個數據庫表單，起名為Studetn。內有：id、name、age、sex四個屬性。將id設為主鍵並且設置自動遞增。

---

 

第二，在數據庫建立完表單之后，在Java中創建一個數據庫表單的實體類。（類名和表名一致）

內有：

　　　　1、表單的屬性值和屬性的基本數據類型。

　　　　2、無參的構造函數。

　　　　3、有參的構造函數。

　　　　4、Get和Set方法。

　　　　5、toString方法。

---

 

第三：創建一個工具類。

內有：

　　　　1、寫一個靜態代碼塊。將注冊驅動寫入其中。

　　　　　  原因：驅動只需要加載一次即可，

　　　　　  　　　所以寫在靜態代碼段中（static），類的靜態代碼塊，隨着類的加載，只執行一次。

　　　　2、將建立連接進行封裝。

　　　　3、將增刪改的通用方法也一並進行封裝。

---

 

第四，先在dao層創建一個接口

內有：

　　　　1、返回值類型和方法名、參數。

　　　　1.1、可根據增刪改分為不同的寫法。

　　　　1.2、兩個以上的參數，全部使用對象傳參。

---

 

第五：在dao層下創建一個包，命名為Impl，在這個包內創建一個接口實現類。

內有：

　　　　1、寫入SQL語句，要增刪改的內容可用占位符代替。

　　　　2、返回在工具類里給增刪改通用方法設定的調用方法。

　　　　3、在返回調用方法里加入占位符所代表的對象。

---

 

第六：在servlet里創建測試類。

內有：

　　　　1、通過創建的實體類來賦值。

　　　　2、通過實現類來調用接口里的方法。

　　　　3、調用方法。

---

 

 

實例：

 

---

第一步：創建數據庫表單。

 

　　　　

 

 

---

 

 第二步： 創建一個數據庫表單的實體類。

 　　　　

package com.Wuchuang.entiy;

public class Student {

    private int id;
    private String name;
    private int age;
    private String sex;


    public Student() {
    }

    public Student(int id, String name, int age, String sex) {
        this.id = id;
        this.name = name;
        this.age = age;
        this.sex = sex;
    }

    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 int getAge() {
        return age;
    }

    public void setAge(int age) {
        this.age = age;
    }

    public String getSex() {
        return sex;
    }

    public void setSex(String sex) {
        this.sex = sex;
    }

    @Override
    public String toString() {
        return "Student{" +
                "id=" + id +
                ", name='" + name + '\'' +
                ", age=" + age +
                ", sex='" + sex + '\'' +
                '}';
    }
}

 

---

第三步：創建一個工具類。

　　　　

package com.Wuchuang.util;

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

public class DBUtil {
    //注冊驅動，驅動只需要加載一次即可
    //所以寫在靜態代碼段中（static）
    //類的靜態代碼塊，隨着類的加載，只執行一次。
    static {
        try {
            Class.forName("com.mysql.jdbc.Driver");
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }
    }
    //建立鏈接。需要單獨創建一個方法。
    //通過返回值返回鏈接對象。
    //鏈接每次用完之后就會關閉。
    public static Connection getConnection() {
        try {
            return DriverManager.getConnection("jdbc:mysql:///test?characterEnconding=UTF-8", "數據庫賬戶", "密碼");
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return null;
    }

    /** 增刪改的通用方法
     * @param  String sql       要執行的sql
     * @param  Object[] obj    對象類型的數組  里面存放着 sql執行的占位符參數
     *         Object...       可變參數
     * */
    public  static  boolean executeUpdate(String sql,Object... args){
        PreparedStatement ps = null;

        try {
            ps = getConnection().prepareStatement(sql);
            for (int i = 0;i<args.length;i++){
                ps.setObject(i+1,args[i]);
            }
            int i = ps.executeUpdate();
            if (i>0)return true;
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {

　　　　　　　　close(conn,ps,null);

　　　　　　}

return false; 

 } 

}

 

     // c查詢的通用方法
    public static List<Map<String,Object>> executeQuery(String sql,Object... args){
        Connection conn = null;
        PreparedStatement ps = null;
        ResultSet set = null;
        try {
            conn = DBUtil.getConnection();
            ps = conn.prepareStatement(sql);
            /* 有可能有參數 */
            for (int i=0;i<args.length;i++){
                ps.setObject(i+1,args[i]);
            }
            /*執行*/
            set = ps.executeQuery();
            /*需要將所有數據都存放到 List中    每一行 用一個 map存放*/
            List<Map<String,Object>> list = new ArrayList<>();
            /*獲取本次查詢結果集有多少列*/
            int count = set.getMetaData().getColumnCount();

            while(set.next()){
                Map<String, Object> map = new HashMap<>();//一行數據 用一個map 接收

                for(int i=0;i<count;i++){
                    String name = set.getMetaData().getColumnLabel(i+1);
                    map.put(name,set.getObject(name));
                }
                /*將每行的map存放到 List中*/
                list.add(map);
            }
            return list;
        } catch (Exception e) {
            e.printStackTrace();
        }finally {
            close(conn,ps,set);
        }
        return null;
    }

    / /關閉的通用方法    
private static void close(Connection conn,PreparedStatement st,ResultSet set){
        try {
            if(set!=null){
                set.close();
            }
            if(st!=null){
                st.close();
            }
            if(conn != null){
                conn.close();
            }
        }catch (Exception e){
            e.printStackTrace();
        }
    }
}

 

---

第四步：在dao層創建一個接口。

package com.Wuchuang.dao;

import com.Wuchuang.entiy.Student;

public interface IStudentDAO {
    /**
     * 添加新學生
     * insert  into student  （name,age,sex） values (?,?,?);
     * 兩個以上的參數 全用對象傳參
     * @param  學生對象 里面存放當着需要添加的學生信息
     * @return  boolean  成功返回 true  失敗 返回 false
     */
        boolean add (Student s);


    /**
     * 根據id刪除學生，所以返回值可以直接填寫id的數據類型和id
     * delete from student where id = ？
     */
        boolean  delete(int  id);


    /**
     * 根據id修改學生
     * update student set name = ？，age= ? where id = ?
     */
        boolean update(Student s);
}

 

---

 

第五步：創建一個接口實現類。

package com.Wuchuang.dao.Impl;

import com.Wuchuang.dao.IStudentDAO;
import com.Wuchuang.entiy.Student;
import com.Wuchuang.util.DBUtil;

public class StudentDAOImpl implements IStudentDAO {
    @Override
    public boolean add(Student s) {
        String sql = "insert into Student (name,age,sex) values (?,?,?)";

        return DBUtil.executeUpdate(sql,s.getName(),s.getAge(),s.getSex());
    }

    @Override
    public boolean delete(int id) {
        String sql = "delete from Student where id = ?";

        return DBUtil.executeUpdate(sql,id);
    }

    @Override
    public boolean update(Student s) {
        String sql = "update Student set name = ?,age = ?,sex = ? where id = ?";

        return DBUtil.executeUpdate(sql,s.getName(),s.getAge(),s.getSex(),s.getId());

    }
}

 

---

 

第六步：進行測試。

package com.Wuchuang.servlet;

import com.Wuchuang.dao.IStudentDAO;
import com.Wuchuang.dao.Impl.StudentDAOImpl;
import com.Wuchuang.entiy.Student;
import org.junit.Test;

public class ServletTest{
    @Test
    public void test(){
        Student s = new Student(1,"吃飯",38,"男");

        IStudentDAO dao =  new StudentDAOImpl();

        dao.add(s);
    }

}

 

---

2019年4月11日17:22:31