JavaWeb (3: JDBC dan MVC)

Untuk menghubungkan database yang berbeda dengan JDBC, Anda hanya perlu memuat paket driver database yang berbeda, dan Anda tidak perlu khawatir tentang perbedaan bahasa pengoperasian database.

2.Tulis program JDBC

① Buat tabel database


CREATE TABLE users(
    id INT PRIMARY KEY,
    `name` VARCHAR(40),
    `password` VARCHAR(40),
    email VARCHAR(60),
    birthday DATE
);
INSERT INTO users(id,`name`,`password`,email,birthday)
VALUES(1,'张三','123456','[email protected]','2000-01-01');
INSERT INTO users(id,`name`,`password`,email,birthday)
VALUES(2,'李四','123456','[email protected]','2000-01-01');
INSERT INTO users(id,`name`,`password`,email,birthday)
VALUES(3,'王五','123456','[email protected]','2000-01-01');
SELECT * FROM users;

② Impor dependensi basis data


<!--mysql的驱动-->
<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>8.0.31</version>
</dependency>

③ Penggunaan JDBC:

Ⅰ.Muat driver database (jembatan antara program java dan database)

Ⅱ. Obtain Connection, koneksi antara program java dengan database

Ⅲ. Buat objek Pernyataan yang mengirimkan SQL ke database, dihasilkan oleh Connection

Ⅳ. Tulis pernyataan SQL (tulis SQL yang berbeda sesuai dengan bisnisnya)

Ⅴ.Jalankan SQL (jika Anda ingin menerima nilai kembalian, buat objek ResultSet untuk menyimpan hasil kueri setelah Pernyataan dijalankan)

Ⅵ


public class JDBCTest {
    public static void main(String[] args) throws Exception {
        //配置信息
        //要连接的数据库URL（解决中文乱码问题：useUnicode=true&characterEncoding=utf8&useSSL=true）
        String url = "jdbc:mysql://localhost:3306/jdbc?useUnicode=true&characterEncoding=utf8&useSSL=true";
        //连接的数据库时使用的用户名
        String username = "root";
        //连接的数据库时使用的密码
        String password = "123456";
        Connection conn = null;
        Statement st = null;
        ResultSet rs = null;
        
        try {
            //1.加载驱动
            Class.forName("com.mysql.cj.jdbc.Driver");
            //2.获取与数据库的链接
            conn = DriverManager.getConnection(url, username, password);
            //3.获取用于向数据库发送sql语句的statement对象
            st = conn.createStatement();
            String sql = "select id,name,password,email,birthday from users";
            //4.向数据库发sql,并获取代表结果集的resultset对象
            //查：executeQuery    增删改：executeUpdate
            rs = st.executeQuery(sql);
            //5.取出结果集的数据
            while (rs.next()) {
                System.out.println("id=" + rs.getInt("id"));
                System.out.println("name=" + rs.getString("name"));
                System.out.println("password=" + rs.getString("password"));
                System.out.println("email=" + rs.getString("email"));
                System.out.println("birthday=" + rs.getDate("birthday"));
            }
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            try {
                //6.关闭链接，释放资源（先开后关）
                rs.close();
                st.close();
                conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

3. Analisis rinci

(1) Url basis data

jdbc:mysql://host lokal:3306/xxx

jdbc	protokol
mysql	sub-protokol
tuan rumah lokal:3306	tuan rumah:pelabuhan
xxx	basis data

Cara menulis alamat URL database yang umum digunakan:

Penulisan Oracle: jdbc:Oracle:thin:@hosting lokal:1521:xxx
Konfigurasi SqlServer: jdbc:microsoft:sqlserver://localhost:1433; DatabaseName=xxx
Metode penulisan MySql: jdbc:mysql://localhost:3306/xxx

(2) Kelas koneksi

Koneksi digunakan untuk mewakili link database, dan Koleksi adalah objek terpenting dalam pemrograman database.

Semua interaksi antara klien dan database diselesaikan melalui objek koneksi., metode umum dari objek ini:

buatPernyataan()	Buat objek pernyataan yang mengirimkan sql ke database
persiapkanPernyataan(sql)	Buat objek PrepareSatement yang mengirimkan sql yang telah dikompilasi ke database
setAutoCommit(boolean autoCommit)	Atur apakah transaksi dilakukan secara otomatis
melakukan()	Kirim transaksi pada tautan
kembalikan()	Kembalikan transaksi pada tautan ini

(3) Kelas pernyataan

Objek pernyataan digunakan untuk mengirim pernyataan SQL ke database. Metode umum objek Pernyataan:

eksekusiQuery(String sql)	Digunakan untuk mengirim pernyataan kueri ke data dan mengembalikan kumpulan hasil ResultSet
eksekusiPembaruan(String sql)	Digunakan untuk mengirim pernyataan penyisipan, pembaruan, atau penghapusan ke database dan mengembalikan jumlah baris yang diperbarui dalam database
eksekusi(String sql)	Digunakan untuk mengirim pernyataan sql sewenang-wenang ke database
tambahkanBatch(String sql)	Masukkan beberapa pernyataan sql ke dalam satu batch
eksekusiBatch()	Kirim sekumpulan pernyataan sql ke database untuk dieksekusi

Melihat:

Untuk meningkatkan efisiensi pengoperasian, metode eksekusi umumnya tidak digunakan secara langsung.

Sebagai gantinya, gunakanlah sesuai dengan: mengeksekusiQuery untuk kueri; mengeksekusiUpdate untuk penambahan, penghapusan, dan modifikasi.

(4) kelas HasilSet

ResultSet digunakan untuk mewakili hasil eksekusi pernyataan Sql.

Kumpulan hasil Saat merangkum kumpulan hasil eksekusi, gunakanmirip dengan tabelJalan。

Objek ResultSet mempertahankan kursor yang menunjuk ke baris data tabel.Awalnya, kursor berada sebelum baris pertama。

Memanggil metode ResultSet.next() dapat membuat kursor menunjuk ke baris data tertentu, dan memanggil metode getxxx untuk mendapatkan data baris tersebut.

① Dapatkan semua jenis data

getObject(int indeks)	Dapatkan objek Object sesuai dengan jumlah kolom yang ditentukan
getObject(string namakolom)	Dapatkan objek Object sesuai dengan nama atribut yang ditentukan

② Mendapatkan data dengan tipe tertentu, seperti mendapatkan tipe String

dapatkanString(int indeks)	Dapatkan objek String berdasarkan jumlah kolom yang ditentukan
getString(String namakolom)	Dapatkan objek String sesuai dengan nama atribut yang ditentukan

③ Cara menggulir kumpulan hasil:

Berikutnya()	pindah ke baris berikutnya
Sebelumnya()	berpindah ke baris sebelumnya
absolut(int baris)	Pindah ke baris yang ditentukan
sebelumPertama()	Pindahkan bagian depan resultSet
setelahTerakhir()	Pindah ke akhir resultSet

(5) Melepaskan sumber daya

Setelah program Jdbc selesai dijalankan, ingatlah untuk melepaskan objek yang dibuat oleh program untuk berinteraksi dengan database selama proses berjalan.

Objek-objek ini biasanya adalah objek ResultSet, Statement, dan Connection.

Khususnya objek Connection, merupakan resource yang sangat langka dan harus segera dilepaskan setelah digunakan.

Jika Koneksi tidak dapat ditutup dengan cepat dan benar, hal ini dapat dengan mudah menyebabkan downtime sistem.

Untuk memastikan kode rilis sumber daya dapat berjalan, kode rilis sumber daya juga harus ditempatkan di pernyataan akhirnya.

4. Masalah injeksi SQL

Ada dua masalah saat menggunakan Pernyataan untuk pengembangan:

① Senar senar harus sering disambung, dan tingkat kesalahannya tinggi


String username = "zhangsan";
String password = "123";
String sql = "select * from users where name='"+username+"' and password='"+password+"'";
ResultSet rs = st.executeQuery(sql);

② Ada potensi risiko injeksi SQL

Injeksi SQL: Memasukkan pernyataan SQL ilegal ke dalam data yang dimasukkan oleh pengguna, menggunakan teknik cerdas untuk menyambung string, menyebabkan korsleting SQL, sehingga mencuri data database.


public class SQLTest {
    public static void main(String[] args) throws Exception {
        // 正常登陆sql：select * from users where name='张三' and password ='123456'
        //login("张三","123456");
        // SQL 注入：select * from users where name='' and password ='123456' or '1'='1'
        login("", "123456' or '1'='1");
    }
 
    public static void login(String username, String password) throws Exception {
        String url = "jdbc:mysql://localhost:3306/jdbc?useUnicode=true&characterEncoding=utf8&useSSL=true";
        String dbUsername = "root";
        String dbPassword = "123456";
 
        //1.加载驱动
        Class.forName("com.mysql.cj.jdbc.Driver");
        //2.获取与数据库的链接
        Connection conn = DriverManager.getConnection(url, dbUsername, dbPassword);
        //3.获取用于向数据库发送sql语句的statement
        Statement st = conn.createStatement();
        String sql = "select * from users where name='" + username + "' and password='" + password + "'";
        System.out.println(sql);
        //4.向数据库发sql,并获取代表结果集的rs
        ResultSet rs = st.executeQuery(sql);
        if (rs.next()) {
            System.out.println("登录成功");
        } else {
            System.out.println("登录失败");
        }
        //6.关闭链接，释放资源
        rs.close();
        st.close();
        conn.close();
    }
}

hasil operasi:

Melihat:

Prioritas dan dalam pernyataan SQL lebih besar dari atau, sehingga SQL yang dieksekusi setara dengan pilih * dari pengguna di mana '1' = '1';

Larutan:Gunakan PreparedStatement, subkelas Pernyataan, yang menyediakan fungsi placeholder SQL.

Tidak perlu menyambung string, dan data yang dimasukkan oleh pengguna akan terdeteksi sepenuhnya, sehingga lebih aman.


public class PSTest {
    public static void main(String[] args) throws Exception {
        // 正常登陆sql：select * from users where name='张三' and password ='123456'
        //login("张三","123456");
        // SQL 注入：select * from users where name='' and password ='123456' or '1'='1'
        login("", "123456' or '1'='1");
    }
 
    public static void login(String username, String password) throws Exception {
        String url = "jdbc:mysql://localhost:3306/jdbc?useUnicode=true&characterEncoding=utf8&useSSL=true";
        String dbUsername = "root";
        String dbPassword = "123456";
 
        Class.forName("com.mysql.cj.jdbc.Driver");
 
        Connection conn = DriverManager.getConnection(url, dbUsername, dbPassword);
        //获取用于向数据库发送预编译sql语句的prepareStatement
        String sql = "select * from users where name = ? and password = ?";
        System.out.println(sql);
        PreparedStatement ps = conn.prepareStatement(sql);
        //给占位符 ? 填充数据
        ps.setString(1, username);
        ps.setString(2, password);
        ResultSet rs = ps.executeQuery();
        if (rs.next()) {
            System.out.println("登录成功");
        } else {
            System.out.println("登录失败");
        }
        rs.close();
        ps.close();
        conn.close();
    }
}

hasil operasi:

5.transaksi JDBC

Suatu transaksi mengacu pada serangkaian operasi logis, baik semuanya berhasil atau semuanya gagal (prinsip ACID).

Ketika program Jdbc memperoleh objek Connection dari database, secara default objek Connection akan secara otomatis mengirimkan transaksi ke database.

Jika Anda ingin menonaktifkan metode pengiriman default ini dan mengizinkan beberapa SQL dieksekusi dalam satu transaksi, Anda dapat menggunakan pernyataan transaksi kontrol JDBC berikut.

Koneksi.setAutoCommit(salah);	memulai transaksi
Koneksi.rollback();	Transaksi pengembalian
Koneksi.komit();	melakukan transaksi

① Buat tabel akun


/*创建账户表*/
CREATE TABLE account(
    id INT PRIMARY KEY AUTO_INCREMENT,
    NAME VARCHAR(40),
    money DECIMAL(9,2)
);
/*插入测试数据*/
insert into account(name,money) values('A',1000);
insert into account(name,money) values('B',1000);
insert into account(name,money) values('C',1000);

② Simulasikan skenario bisnis ketika transfer berhasil


//失败后让数据库自动回滚事务
public class Demo {
    public static void main(String[] args) {
        String url = "jdbc:mysql://localhost:3306/jdbc?useUnicode=true&characterEncoding=utf8&useSSL=true";
        String username = "root";
        String password = "123456";
        Connection conn = null;
        try {
            Class.forName("com.mysql.cj.jdbc.Driver");
            conn = DriverManager.getConnection(url, username, password);
 
            //通知数据库开启事务，false表示开启
            conn.setAutoCommit(false);
 
            String sql1 = "update account set money=money-100 where name = 'A' ";
            conn.prepareStatement(sql1).executeUpdate();
 
            //模拟执行完SQL1之后程序出现了异常而导致后面的SQL无法正常执行，事务也无法正常提交
            int x = 1/0;
 
            String sql2 = "update account set money=money+100 where name = 'B' ";
            conn.prepareStatement(sql2)executeUpdate();
 
            //sql1 和 sql2都顺利执行，就提交事务
            conn.commit();
            System.out.println("成功！！！");
        } catch (Exception e) {
            //出现异常，通知数据库回滚事务
            conn.rollback();
            e.printStackTrace();
        } finally {
            conn.close();
        }
    }
}

6. Kelas alat JDBC

Dalam permintaan yang berbeda, Anda perlu terhubung ke database dan melepaskan sumber daya setiap kali, dan banyak kode berulang akan ditulis.

Enkapsulasi operasi persiapan dan pelepasan koneksi database ke dalam kelas alat, dan panggil secara langsung saat menggunakannya untuk menghindari penulisan kode berulang.


public class JdbcUtil {
    private static Connection connection;
    private static String url = "jdbc:mysql://localhost:3306/jdbc?useUnicode=true&characterEncoding=utf8&useSSL=true";
    private static String username = "root";
    private static String password = "123456";
 
    //驱动（类）只需要加载一次，放静态代码块即可
    static {
        try {
            //加载数据库驱动
            Class.forName("com.mysql.cj.jdbc.Driver");
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
 
    // 获取数据库连接对象
    public static Connection getConnection() throws SQLException {
        return DriverManager.getConnection(url, username, password);
    }
 
    // 释放资源（利用多态：Statement 和 PreparedStatement 都可以传进来）
    public static void release(Connection conn, Statement st, ResultSet rs) {
        try {
            if (rs != null) {
                rs.close();
            }
            if (st != null) {
                st.close();
            }
            if (conn != null) {
                conn.close();
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

Kasus panggilan, seperti: tambahkan pengguna


 
    public void add(String name, String password) {
        Connection conn = null;
        PreparedStatement ps = null;
        try {
            conn = JdbcUtil.getConnection();
            String sql = "insert into users(name,password) values(?,?)";
            ps = conn.prepareStatement(sql);
            ps.setString(1, name);
            ps.setString(2, password);
            ps.executeUpdate();
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            JdbcUtil.release(conn, ps, null);
        }
    }

7. Kumpulan koneksi database

(1 Ikhtisar

Proses pengembangan JDBC:

Ⅰ. Muat driver database (hanya perlu dimuat satu kali)

Ⅱ. Membangun koneksi database (Koneksi)

Ⅲ. Buat objek Pernyataan yang mengirimkan SQL ke database, dihasilkan oleh Connection

Ⅳ. Menulis pernyataan SQL

Ⅴ.Jalankan SQL (Query-->objek ResultSet menerima kumpulan hasil)

Ⅵ. Tutup koneksi dan lepaskan sumber daya

Objek koneksi database diperoleh melalui DriverManager. Setiap kali diperoleh, Anda perlu mendaftar ke database untuk mendapatkan koneksi dan memverifikasi nama pengguna dan kata sandi.

Pengguna perlu mendapatkan tautan dari database untuk setiap permintaan, dan membuat koneksi ke database biasanya menghabiskan sumber daya yang relatif besar dan membutuhkan waktu lama untuk membuatnya.

Setiap kali pernyataan SQL dijalankan, koneksi terputus, yang akan menyebabkan pemborosan sumber daya dan sumber daya koneksi database tidak digunakan kembali dengan baik.

Dengan asumsi bahwa situs web menerima 100.000 kunjungan setiap hari, server database perlu membuat 100.000 koneksi, yang merupakan pemborosan sumber daya database dan dapat dengan mudah menyebabkan kelebihan memori server database dan perluasan mesin.

Solusi: Kumpulan koneksi database

Ide dasar kumpulan koneksi database:

Buat kumpulan buffer untuk database dan masukkan sejumlah objek koneksi ke dalam kumpulan buffer terlebih dahulu.

Saat ingin mendapatkan koneksi database, Anda hanya perlu mengambil objek dari buffer pool.

Setelah digunakan, masukkan kembali ke dalam kumpulan buffer untuk permintaan berikutnya, sehingga sumber daya dapat digunakan kembali tanpa perlu pembuatan berulang kali.

Ketika tidak ada objek koneksi yang menganggur di kumpulan koneksi database, permintaan baru akan masuk ke antrian tunggu dan menunggu thread lain melepaskan koneksi.

(2) Gunakan

Kumpulan koneksi database JDBC diselesaikan menggunakan antarmuka javax.sql.DataSource. DataSource adalah antarmuka resmi yang disediakan oleh Java.

Saat menggunakannya, pengembang tidak perlu mengimplementasikan antarmukanya sendiri dan dapat menggunakan alat pihak ketiga.

C3P0 adalah implementasi pihak ketiga yang umum digunakan. Dalam pengembangan sebenarnya, C3P0 dapat digunakan secara langsung untuk menyelesaikan pengoperasian kumpulan koneksi database.

Langkah-langkah penggunaan:

① Impor dependensi di pom.xml


	<dependency>
	    <groupId>com.mchange</groupId>
	    <artifactId>c3p0</artifactId>
	    <version>0.9.5.2</version>
	</dependency>

② Tulis kode


public class DataSourceTest {
    public static void main(String[] args) {
        try {
            //创建C3P0数据库连接池
            ComboPooledDataSource dataSource=new ComboPooledDataSource();
            dataSource.setDriverClass("com.mysql.cj.jdbc.Driver");
            dataSource.setJdbcUrl("jdbc:mysql://localhost:3306/jdbc?useUnicode=true&characterEncoding=utf8");
            dataSource.setUser("root");
            dataSource.setPassword("123456");
            //设置初始化连接个数
            dataSource.setInitialPoolSize(5);
            //设置最大连接个数（连接池中不够，可以继续申请，申请后最终的上限）
            dataSource.setMaxPoolSize(20);
            //当连接对象不够时，再次申请的连接对象个数
            dataSource.setAcquireIncrement(5);
            //设置最小连接数（当连接池中剩余2个连接对象时，就去申请 --> 提前做准备）
            dataSource.setMinPoolSize(2);
            Connection conn=dataSource.getConnection();
 
            //SQL操作...
 
            //将连接还回到数据库连接池中
            conn.close();
        } catch (PropertyVetoException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

Melihat:

Koneksi diperoleh melalui metode tradisional: com.mysql.cj.jdbc.ConnectionImpl@3c153a1

Koneksi diperoleh oleh C3P0: com.mchange.v2.c3p0.impl.NewProxyConnection@6156496

Jadi,Walaupun semuanya memanggil metode close, kelas implementasinya berbeda, sehingga penulisan ulang metodenya juga berbeda. Ini adalah polimorfisme antarmuka.。

Metode close di C3P0 tidak secara langsung menghancurkan sumber daya koneksi, namun mengembalikan koneksi ke kumpulan koneksi database.

Metode pengaturan parameter kumpulan koneksi database di atas ditulis langsung di program Java.

Ini diadopsiKode kerasJalan,Setiap kali Anda mengubah konfigurasiPerlu dikompilasi ulang, menghasilkan file kelas baru, efisiensinya terlalu rendah。

Dalam pengembangan sebenarnya, informasi konfigurasi C3P0 didefinisikan dalam file xml, dan program java hanya perlu memuat file konfigurasi untuk menyelesaikan operasi inisialisasi kumpulan koneksi database.

Selanjutnya Anda hanya perlu memodifikasi konfigurasi dan memodifikasi konfigurasi di xml tanpa melakukan kompilasi ulang.

Langkah-langkah penggunaan:

① Di direktori sumber daya, buat file baru bernama c3p0-config.xml

② Isi informasi konfigurasi di c3p0-config.xml:


<?xml version="1.0" encoding="UTF-8"?>
<c3p0-config>
    <!--配置连接池mysql-->
    <named-config name="C3P0Test">
        <!--   指定连接数据源的基本属性     -->
        <property name="driverClass">com.mysql.cj.jdbc.Driver</property>
        <property name="jdbcUrl">jdbc:mysql://localhost:3306/jdbc?useUnicode=true&amp;characterEncoding=utf8</property>
        <property name="user">root</property>
        <property name="password">123456</property>
 
        <!--   设置初始化连接个数     -->
        <property name="initialPoolSize">5</property>
        <!--   设置最大连接个数（连接池中不够，可以继续申请，申请后最终的上限）     -->
        <property name="maxPoolSize">20</property>
        <!--   当连接对象不够时，再次申请的连接对象个数     -->
        <property name="acquireIncrement">5</property>
        <!--   设置最小连接数（当连接池中剩余2个连接对象时，就去申请 -> 提前做准备） -->
        <property name="minPoolSize">2</property>
    </named-config>
</c3p0-config>

③Tulis program Java


public class DataSourceTest {
    public static void main(String[] args) {
        try {
            //创建C3P0数据库连接池
            ComboPooledDataSource dataSource=new ComboPooledDataSource("C3P0Test");
            Connection conn=dataSource.getConnection();
            System.out.println(conn);
            //将连接还回到数据库连接池中
            conn.close();
        }catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

Melihat:

① Parameter dalam metode konstruksi ComboPooledDataSource adalah nilai atribut nama dari tag bernama-config yang dikonfigurasi di c3p0-config.xml.

② Saat ini, kelas alat JDBC dapat dimodifikasi sebagai:


public class JdbcUtil {
    private static DataSource dataSource;
 
    static {
        dataSource = new ComboPooledDataSource("C3P0Test");
    }
 
    // 获取数据库连接对象
    public static Connection getConnection() throws SQLException {
        Connection conn = null;
        try {
            conn = dataSource.getConnection();
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return conn;
    }
 
    // 释放资源（利用多态：Statement 和 PreparedStatement 都可以传进来）
    public static void release(Connection conn, Statement st, ResultSet rs) {
        try {
            if (rs != null) {
                rs.close();
            }
            if (st != null) {
                st.close();
            }
            if (conn != null) {
                conn.close();
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

8.DBUtil


    public static Student findById(Integer idx) {
        Connection conn = null;
        PreparedStatement st = null;
        ResultSet rs = null;
        Student stu = null;
        try {
            conn = JdbcUtil.getConnection();
 
            String sql = "select * from student where id = ?";
            PreparedStatement ps = conn.prepareStatement(sql);
            //给占位符 ? 填充数据
            ps.setInt(1, idx);
            rs = ps.executeQuery();
            //取出结果集的数据
            while (rs.next()) {
                Integer id = rs.getInt(1);
                String name = rs.getString(2);
                Double score = rs.getDouble(3);
                Date birthday = rs.getDate(4);
                stu = new Student(id, name, score, birthday);
            }
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            try {
                //关闭链接，释放资源
                rs.close();
                st.close();
                conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        return stu;
    }

Dalam kode di atas, operasi pengisian placeholder dengan data dan mengekstraksi data dari kumpulan hasil terlalu rumit.

Jika ada 100 atribut dalam tabel Siswa, maka kita harus menulis 100 baris dalam perulangan while untuk mengambil datanya, dan mungkin juga diperlukan banyak baris untuk mengisi placeholder.

Larutan:DBUtils dapat membantu pengembang menyelesaikan enkapsulasi data (pemetaan kumpulan hasil ke objek Java).

Langkah-langkah penggunaan:

① Impor dependensi di pom.xml


<dependency>
	<groupId>commons-dbutils</groupId>
	<artifactId>commons-dbutils</artifactId>
	<version>1.6</version>
</dependency>

② Tulis kode


    public static Student findById(Integer idx) {
        Connection conn = null;
        Student stu = null;
        try {
            conn = JdbcUtil.getConnection();
 
            String sql = "select * from student where id = ?";
            //使用DBUtils
            QueryRunner qr = new QueryRunner();
            stu = qr.query(conn, sql, new BeanHandler<>(Student.class), idx);
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            try {
                //关闭链接，释放资源
                conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        return stu;
    }

Pada titik ini, mengisi placeholder dan mengeluarkan kumpulan hasil dapat dilakukan dengan dua baris kode.

rincian:

① Metode kueri harus memasukkan 4 parameter:

Objek koneksi

pernyataan SQL

Objek kelas implementasi antarmuka ResultSetHandler (tipe objek yang dikonversi harus: Student.class)

Parameter untuk mengisi placeholder

② Antarmuka ResultSetHandler digunakan untuk memproses kumpulan hasil. Ia dapat mengubah kumpulan hasil yang ditanyakan menjadi objek Java berikut.

Penangan Kacang	Petakan hasil yang ditetapkan ke dalam objek Java (seperti objek Siswa)
Penanganan Daftar Kacang	Petakan kumpulan hasil ke dalam kumpulan Daftar (seperti: Daftar<Student > )
Penangan Peta	Petakan kumpulan hasil ke dalam objek koleksi Peta (yaitu: Peta<String,Object> kunci: nama atribut; nilai: nilai atribut)
PenanganDaftarPeta	Petakan kumpulan hasil ke dalam koleksi MapList (yaitu: List <Map<<String,Object> >)

③ Parameter untuk mengisi placeholder adalah parameter variabel, sehingga sejumlah parameter dapat diteruskan untuk memenuhi kebutuhan pengguna yang berbeda.

④ Kelas objek yang dikonversi (kelas Siswa) harus memiliki konstruktor tanpa parameter, jika tidak, program akan melaporkan kesalahan.

alasan:Lapisan bawah menemukan kelas ini melalui Student.class, dan kemudian melaluimekanisme refleksiTemukan konstruktor tanpa parameter dari kelas ini dan buat objeknya.

⑤ Nama atribut pada kelas harus sama persis dengan nama field pada tabel database.

Karena setelah objek dibuat, ketika memberikan nilai pada properti objek berdasarkan kumpulan hasil, pencarian dan penugasan dilakukan berdasarkan namanya.

11. Arsitektur tiga tingkat MVC

Apa itu MVC?

Model: model (layanan, dao, entitas)
Tampilan: Tampilan (jsp, html, klien aplikasi)
Pengontrol: Pengontrol (Servlet, Hander, Aksi)

Setelah permintaan masuk ke aplikasi JavaWeb, Pengontrol menerima permintaan tersebut, melakukan pemrosesan logika bisnis, dan terakhir mengembalikan hasilnya kepada pengguna (Tampilan + Model).

1. Perkenalan

Pada tahun-tahun awal, ketika mengoperasikan aplikasi web, pengguna langsung mengakses lapisan kontrol, dan lapisan kontrol dapat langsung mengoperasikan database:

servlet--CRUD (menambah, menghapus, memodifikasi)-->database

Dalam kode servlet: memproses permintaan, respons, lompatan tampilan, pemrosesan JDBC, pemrosesan kode bisnis, dan pemrosesan kode logika

Kekurangan:Program ini sangat membengkak dan tidak kondusif untuk pemeliharaan

larutan: Tidak ada yang tidak dapat diselesaikan dengan menambahkan lapisan lain, jika ada, tambahkan lapisan lain!

2. arsitektur tiga tingkat mvc

Model

Pemrosesan bisnis: logika bisnis (Layanan)
Lapisan persistensi data: CRUD (objek persistensi data DAO)

melihat

menampilkan data
Berikan tautan untuk memulai permintaan Servlet (a, form, img...)

Pengendali (Servlet)

Menerima permintaan pengguna: (persyaratan, parameter permintaan, informasi sesi)
Serahkan ke lapisan bisnis untuk memproses kode yang sesuai
Kontrol tampilan melompat

Ambil login pengguna dan administrator sebagai contoh:

Lapisan pengontrol:


@WebServlet("/login")
public class LoginServlet extends HttpServlet {
 
    private LoginService loginService = new LoginServiceImpl();
 
    /* 处理登录的业务逻辑*/
    @Override
    protected void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
        String username = req.getParameter("username");
        String password = req.getParameter("password");
        String type = req.getParameter("type");
        Object object = loginService.login(username,password,type);
        if(object != null){
            HttpSession session = req.getSession();
            switch (type){
                case "reader":
                    Reader reader = (Reader) object;
                    session.setAttribute("reader",reader);
                    //跳转到用户的首页
                    resp.sendRedirect("/book?page=1");
                    break;
                case "admin":
                    Admin admin = (Admin) object;
                    session.setAttribute("admin",admin);
                    //跳转到管理员的首页
                    resp.sendRedirect("/admin?method=findAllBorrow&page=1");
                    break;
            }
        }else{
            resp.sendRedirect("login.jsp");
        }
    }
 
}

Lapisan layanan:


public interface LoginService {
    //利用多态，动态返回不同类型的对象
    public Object login(String username,String password,String type);
}


public class LoginServiceImpl implements LoginService {
 
    private ReaderRepository readerRepository = new ReaderRepositoryImpl();
    private AdminRepository adminRepository = new AdminRepositoryImpl();
 
    @Override
    public Object login(String username, String password,String type) {
        Object object = null;
        //业务逻辑处理：根据type的值，来选择调用不同的登录方法，去查找不同的表
        switch (type){
            case "reader":
                object = readerRepository.login(username,password);
                break;
            case "admin":
                object = adminRepository.login(username, password);
                break;
        }
        return object;
    }
}

Lapisan Dao/Repositori:


public interface AdminRepository {
    public Admin login(String username,String password);
}


public interface ReaderRepository {
    public Reader login(String username,String password);
}


public class AdminRepositoryImpl implements AdminRepository {
    //管理员的登录方法（和数据库交互）
    @Override
    public Admin login(String username, String password) {
        Connection connection = JDBCTools.getConnection();
        String sql = "select * from bookadmin where username = ? and password = ?";
        PreparedStatement statement = null;
        ResultSet resultSet = null;
        Admin admin = null;
        try {
            statement = connection.prepareStatement(sql);
            statement.setString(1,username);
            statement.setString(2,password);
            resultSet = statement.executeQuery();
            if(resultSet.next()){
                admin = new Admin(resultSet.getInt(1),resultSet.getString(2),resultSet.getString(3));
            }
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            JDBCTools.release(connection,statement,resultSet);
        }
        return admin;
    }
}


public class ReaderRepositoryImpl implements ReaderRepository {
    //用户的登录方法（和数据库交互）
    @Override
    public Reader login(String username, String password) {
        Connection connection = JDBCTools.getConnection();
        String sql = "select * from reader where username = ? and password = ?";
        PreparedStatement statement = null;
        ResultSet resultSet = null;
        Reader reader = null;
        try {
            statement = connection.prepareStatement(sql);
            statement.setString(1,username);
            statement.setString(2,password);
            resultSet = statement.executeQuery();
            if(resultSet.next()){
                reader = new Reader(resultSet.getInt(1),resultSet.getString(2),resultSet.getString(3),resultSet.getString(4),resultSet.getString(5),resultSet.getString(6),resultSet.getString(7));
            }
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            JDBCTools.release(connection,statement,resultSet);
        }
        return reader;
    }
}

Berbagi teknologi