기술나눔

JavaWeb(3: JDBC 및 MVC)

2024-07-12

한어Русский языкEnglishFrançaisIndonesianSanskrit日本語DeutschPortuguêsΕλληνικάespañolItalianoSuomalainenLatina

JavaWeb(1:기본지식 및 환경구축)아이콘-기본.png?t=N7T8https://blog.csdn.net/xpy2428507302/article/details/140365130?spm=1001.2014.3001.5501JavaWeb(2: 서블릿과 Jsp, 리스너와 필터)아이콘-기본.png?t=N7T8https://blog.csdn.net/xpy2428507302/article/details/140365159?spm=1001.2014.3001.5501

목차

10. JDBC

1. 개요

2.JDBC 프로그램 작성

3. 상세 분석

(1) 데이터베이스 URL

(2) 연결 클래스

(3) 진술 클래스

(4) ResultSet 클래스

(5) 자원 공개

4.SQL 인젝션 문제

5.JDBC 트랜잭션

6.JDBC 도구 클래스

7. 데이터베이스 연결 풀

(1. 개요

(2) 용도

8.DB유틸리티

11. MVC 3계층 아키텍처

1. 소개

2. mvc 3티어 아키텍처

10. JDBC

1. 개요

JDBC(Java DataBase Connectivity): 자바 데이터베이스 연결 기술

JDBC는 특정 데이터베이스와 독립적인 관리 시스템이자 범용 SQL 데이터베이스 액세스 및 운영을 위한 공용 인터페이스입니다.

다양한 데이터베이스에 액세스할 수 있는 통합된 방법을 제공하기 위한 일련의 표준을 정의합니다.

JDBC는 Java 언어로 작성된 클래스와 인터페이스 집합으로 구성된 데이터베이스 액세스를 위한 애플리케이션 API입니다.

두 가지 레벨이 포함됩니다:

① 프로그래머가 호출할 수 있는 애플리케이션 중심의 API입니다.

② 제조업체가 데이터베이스 드라이버를 개발할 수 있는 데이터베이스 지향 API입니다.

서로 다른 데이터베이스를 JDBC로 연결하려면 서로 다른 데이터베이스 드라이버 패키지만 로드하면 되며, 데이터베이스 운영 언어의 차이에 대해 걱정할 필요가 없습니다.

2.JDBC 프로그램 작성

① 데이터베이스 테이블 생성

  1. CREATE TABLE users(
  2.     id INT PRIMARY KEY,
  3.     `name` VARCHAR(40),
  4.     `password` VARCHAR(40),
  5.     email VARCHAR(60),
  6.     birthday DATE
  7. );
  8. INSERT INTO users(id,`name`,`password`,email,birthday)
  9. VALUES(1,'张三','123456','[email protected]','2000-01-01');
  10. INSERT INTO users(id,`name`,`password`,email,birthday)
  11. VALUES(2,'李四','123456','[email protected]','2000-01-01');
  12. INSERT INTO users(id,`name`,`password`,email,birthday)
  13. VALUES(3,'王五','123456','[email protected]','2000-01-01');
  14. SELECT * FROM users;

② 데이터베이스 종속성 가져오기

  1. <!--mysql的驱动-->
  2. <dependency>
  3.     <groupId>mysql</groupId>
  4.     <artifactId>mysql-connector-java</artifactId>
  5.     <version>8.0.31</version>
  6. </dependency>

③ JDBC 사용:

Ⅰ. 데이터베이스 드라이버 로드(Java 프로그램과 데이터베이스 간의 브리지)

Ⅱ. 자바 프로그램과 데이터베이스 간의 연결인 Obtain Connection

Ⅲ. Connection에 의해 생성된 SQL을 데이터베이스로 보내는 State 객체를 생성합니다.

IV.SQL 문 작성(업무에 따라 다른 SQL 작성)

Ⅴ. SQL을 실행한다. (반환값을 받고 싶다면 ResultSet 객체를 생성하여 SQL문 실행 후 쿼리 결과를 저장한다.)

Ⅵ. 연결을 닫습니다.

  1. public class JDBCTest {
  2.     public static void main(String[] args) throws Exception {
  3.         //配置信息
  4.         //要连接的数据库URL（解决中文乱码问题：useUnicode=true&characterEncoding=utf8&useSSL=true）
  5.         String url = "jdbc:mysql://localhost:3306/jdbc?useUnicode=true&characterEncoding=utf8&useSSL=true";
  6.         //连接的数据库时使用的用户名
  7.         String username = "root";
  8.         //连接的数据库时使用的密码
  9.         String password = "123456";
  10.         Connection conn = null;
  11.         Statement st = null;
  12.         ResultSet rs = null;
  13.         
  14.         try {
  15.             //1.加载驱动
  16.             Class.forName("com.mysql.cj.jdbc.Driver");
  17.             //2.获取与数据库的链接
  18.             conn = DriverManager.getConnection(url, username, password);
  19.             //3.获取用于向数据库发送sql语句的statement对象
  20.             st = conn.createStatement();
  21.             String sql = "select id,name,password,email,birthday from users";
  22.             //4.向数据库发sql,并获取代表结果集的resultset对象
  23.             //查：executeQuery    增删改：executeUpdate
  24.             rs = st.executeQuery(sql);
  25.             //5.取出结果集的数据
  26.             while (rs.next()) {
  27.                 System.out.println("id=" + rs.getInt("id"));
  28.                 System.out.println("name=" + rs.getString("name"));
  29.                 System.out.println("password=" + rs.getString("password"));
  30.                 System.out.println("email=" + rs.getString("email"));
  31.                 System.out.println("birthday=" + rs.getDate("birthday"));
  32.             }
  33.         } catch (ClassNotFoundException e) {
  34.             e.printStackTrace();
  35.         } catch (SQLException e) {
  36.             e.printStackTrace();
  37.         } finally {
  38.             try {
  39.                 //6.关闭链接，释放资源（先开后关）
  40.                 rs.close();
  41.                 st.close();
  42.                 conn.close();
  43.             } catch (SQLException e) {
  44.                 e.printStackTrace();
  45.             }
  46.         }
  47.     }
  48. }

3. 상세 분석

(1) 데이터베이스 URL

jdbc:mysql://localhost:3306/xxx

제이디비씨규약
마이스클하위 프로토콜
로컬호스트:3306호스트:포트
트리플 엑스데이터 베이스

일반적으로 사용되는 데이터베이스 URL 주소를 작성하는 방법:

  • Oracle 작성: jdbc:oracle:thin:@로컬호스트:1521:xxx
  • SqlServer 메서드: jdbc:microsoft:sqlserver://localhost:1433; DatabaseName=xxx
  • MySql 작성 방법: jdbc:mysql://localhost:3306/xxx

(2) 연결 클래스

Connection은 데이터베이스 링크를 표현하는데 사용되며, Collection은 데이터베이스 프로그래밍에서 가장 중요한 객체입니다.

클라이언트와 데이터베이스 간의 모든 상호 작용은 연결 개체를 통해 완료됩니다., 이 개체의 일반적인 메서드:

createStatement()SQL을 데이터베이스로 보내는 명령문 개체를 만듭니다.
SQL문 준비(SQL)미리 컴파일된 SQL을 데이터베이스로 보내는 prepareSatement 개체를 만듭니다.
setAutoCommit(boolean 자동커밋)트랜잭션이 자동으로 커밋되는지 여부 설정
저지르다()링크로 거래 제출
롤백()이 링크에서 트랜잭션 롤백

(3) 진술 클래스

명령문 개체는 SQL 문을 데이터베이스로 보내는 데 사용됩니다. 명령문 개체의 일반적인 방법은 다음과 같습니다.

executeQuery(문자열 sql)쿼리 문을 데이터에 보내고 ResultSet 결과 집합을 반환하는 데 사용됩니다.
executeUpdate(문자열 sql)삽입, 업데이트 또는 삭제 문을 데이터베이스로 보내고 데이터베이스에서 업데이트된 행 수를 반환하는 데 사용됩니다.
실행(문자열 sql)임의의 SQL 문을 데이터베이스로 보내는 데 사용됩니다.
addBatch(문자열 sql)여러 SQL 문을 일괄 처리에 넣기
실행배치()실행을 위해 일괄 SQL 문을 데이터베이스로 보냅니다.

알아채다:

작업 효율성을 높이기 위해 일반적으로 실행 메서드를 직접 사용하지 않습니다.

대신에 쿼리에 대해 ExecuteQuery를 사용하고, 추가, 삭제 및 수정에 대해 ExecuteUpdate를 사용하십시오.

(4) ResultSet 클래스

ResultSet은 SQL 문의 실행 결과를 나타내는 데 사용됩니다.

결과 집합 실행 결과 집합을 캡슐화할 때 다음을 사용합니다.테이블과 비슷방법。

ResultSet 객체는 테이블 데이터 행을 가리키는 커서를 유지합니다.처음에는 커서가 첫 번째 행 앞에 있습니다.。

ResultSet.next() 메서드를 호출하면 커서가 특정 데이터 행을 가리키도록 할 수 있고, getxxx 메서드를 호출하여 해당 행의 데이터를 가져올 수 있습니다.

① 모든 유형의 데이터 가져오기

getObject(int 인덱스)

지정된 열 수에 따라 Object 개체를 가져옵니다.

getObject(문자열 열 이름)지정된 속성 이름에 따라 Object 객체를 가져옵니다.

② 문자열 유형 가져오기 등 지정된 유형의 데이터를 가져옵니다.

getString(인덱스)

지정된 열 수를 기반으로 String 객체를 가져옵니다.

getString(문자열 열 이름)지정된 속성 이름에 따라 String 객체를 가져옵니다.

③ 결과 세트를 스크롤하는 방법: 

다음()다음 줄로 이동
이전의()이전 줄로 이동
절대(int 행)지정된 줄로 이동
beforeFirst()resultSet 앞으로 이동
afterLast()resultSet의 끝으로 이동

(5) 자원 공개

Jdbc 프로그램 실행이 완료된 후 실행 프로세스 중에 데이터베이스와 상호 작용하기 위해 프로그램에서 생성된 개체를 해제해야 합니다.

이러한 객체는 일반적으로 ResultSet, State 및 Connection 객체입니다.

특히 Connection 개체는 매우 희귀한 리소스이므로 사용 후 즉시 해제해야 합니다.

연결을 신속하고 정확하게 종료할 수 없으면 쉽게 시스템 다운타임이 발생할 수 있습니다.

리소스 릴리스 코드가 실행될 수 있도록 하려면 리소스 릴리스 코드도 finally 문에 배치되어야 합니다.

4.SQL 인젝션 문제

개발을 위해 State를 사용할 때 두 가지 문제가 있습니다.

① 문자열을 자주 이어붙여야 하고 오류율이 높다.

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

② SQL 인젝션의 위험성이 있다

SQL 삽입: 사용자가 입력한 데이터에 불법적인 SQL 문을 삽입하는 영리한 기술을 사용하여 문자열을 연결하고 SQL 단락을 유발하여 데이터베이스 데이터를 훔치는 행위입니다.

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

작업 결과:

알아채다:

SQL 문에서 및의 우선 순위는 or보다 크므로 실행된 SQL은 '1' = '1'인 사용자로부터 *를 선택하는 것과 동일합니다.

해결책:SQL 자리표시자 기능을 제공하는 SQL문의 하위 클래스인 ReadyStatement를 사용하세요.

문자열을 이어붙일 필요가 없으며 사용자가 입력한 데이터가 완전히 감지되므로 더욱 안전합니다.

  1. public class PSTest {
  2.     public static void main(String[] args) throws Exception {
  3.         // 正常登陆sql：select * from users where name='张三' and password ='123456'
  4.         //login("张三","123456");
  5.         // SQL 注入：select * from users where name='' and password ='123456' or '1'='1'
  6.         login("", "123456' or '1'='1");
  7.     }
  8.  
  9.     public static void login(String username, String password) throws Exception {
  10.         String url = "jdbc:mysql://localhost:3306/jdbc?useUnicode=true&characterEncoding=utf8&useSSL=true";
  11.         String dbUsername = "root";
  12.         String dbPassword = "123456";
  13.  
  14.         Class.forName("com.mysql.cj.jdbc.Driver");
  15.  
  16.         Connection conn = DriverManager.getConnection(url, dbUsername, dbPassword);
  17.         //获取用于向数据库发送预编译sql语句的prepareStatement
  18.         String sql = "select * from users where name = ? and password = ?";
  19.         System.out.println(sql);
  20.         PreparedStatement ps = conn.prepareStatement(sql);
  21.         //给占位符 ? 填充数据
  22.         ps.setString(1, username);
  23.         ps.setString(2, password);
  24.         ResultSet rs = ps.executeQuery();
  25.         if (rs.next()) {
  26.             System.out.println("登录成功");
  27.         } else {
  28.             System.out.println("登录失败");
  29.         }
  30.         rs.close();
  31.         ps.close();
  32.         conn.close();
  33.     }
  34. }

작업 결과:

5.JDBC 트랜잭션

트랜잭션은 모두 성공하거나 모두 실패하는 논리적 작업 집합을 나타냅니다(ACID 원칙).

Jdbc 프로그램이 데이터베이스에서 Connection 개체를 얻으면 기본적으로 Connection 개체는 자동으로 데이터베이스에 트랜잭션을 제출합니다.

이 기본 제출 방법을 끄고 하나의 트랜잭션에서 여러 SQL이 실행되도록 하려면 다음 JDBC 제어 트랜잭션 문을 사용할 수 있습니다.

연결.setAutoCommit(false);

거래 시작
연결.롤백();롤백 트랜잭션
연결.commit();트랜잭션 커밋

① 계정 테이블 생성

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

② 양도 성공 시 사업 시나리오를 시뮬레이션

  1. //失败后让数据库自动回滚事务
  2. public class Demo {
  3.     public static void main(String[] args) {
  4.         String url = "jdbc:mysql://localhost:3306/jdbc?useUnicode=true&characterEncoding=utf8&useSSL=true";
  5.         String username = "root";
  6.         String password = "123456";
  7.         Connection conn = null;
  8.         try {
  9.             Class.forName("com.mysql.cj.jdbc.Driver");
  10.             conn = DriverManager.getConnection(url, username, password);
  11.  
  12.             //通知数据库开启事务，false表示开启
  13.             conn.setAutoCommit(false);
  14.  
  15.             String sql1 = "update account set money=money-100 where name = 'A' ";
  16.             conn.prepareStatement(sql1).executeUpdate();
  17.  
  18.             //模拟执行完SQL1之后程序出现了异常而导致后面的SQL无法正常执行，事务也无法正常提交
  19.             int x = 1/0;
  20.  
  21.             String sql2 = "update account set money=money+100 where name = 'B' ";
  22.             conn.prepareStatement(sql2)executeUpdate();
  23.  
  24.             //sql1 和 sql2都顺利执行，就提交事务
  25.             conn.commit();
  26.             System.out.println("成功！！！");
  27.         } catch (Exception e) {
  28.             //出现异常，通知数据库回滚事务
  29.             conn.rollback();
  30.             e.printStackTrace();
  31.         } finally {
  32.             conn.close();
  33.         }
  34.     }
  35. }

6.JDBC 도구 클래스

다양한 요청에서는 매번 데이터베이스에 연결하고 리소스를 해제해야 하며, 반복되는 코드가 많이 작성됩니다.

데이터베이스 연결 준비 및 해제 작업을 도구 클래스로 캡슐화하고, 반복되는 코드 작성을 피하기 위해 이를 사용할 때 직접 호출합니다.

  1. public class JdbcUtil {
  2.     private static Connection connection;
  3.     private static String url = "jdbc:mysql://localhost:3306/jdbc?useUnicode=true&characterEncoding=utf8&useSSL=true";
  4.     private static String username = "root";
  5.     private static String password = "123456";
  6.  
  7.     //驱动（类）只需要加载一次，放静态代码块即可
  8.     static {
  9.         try {
  10.             //加载数据库驱动
  11.             Class.forName("com.mysql.cj.jdbc.Driver");
  12.         } catch (Exception e) {
  13.             e.printStackTrace();
  14.         }
  15.     }
  16.  
  17.     // 获取数据库连接对象
  18.     public static Connection getConnection() throws SQLException {
  19.         return DriverManager.getConnection(url, username, password);
  20.     }
  21.  
  22.     // 释放资源（利用多态：Statement 和 PreparedStatement 都可以传进来）
  23.     public static void release(Connection conn, Statement st, ResultSet rs) {
  24.         try {
  25.             if (rs != null) {
  26.                 rs.close();
  27.             }
  28.             if (st != null) {
  29.                 st.close();
  30.             }
  31.             if (conn != null) {
  32.                 conn.close();
  33.             }
  34.         } catch (SQLException e) {
  35.             e.printStackTrace();
  36.         }
  37.     }
  38. }

다음과 같은 콜 케이스: 사용자 추가

  1.  
  2.     public void add(String name, String password) {
  3.         Connection conn = null;
  4.         PreparedStatement ps = null;
  5.         try {
  6.             conn = JdbcUtil.getConnection();
  7.             String sql = "insert into users(name,password) values(?,?)";
  8.             ps = conn.prepareStatement(sql);
  9.             ps.setString(1, name);
  10.             ps.setString(2, password);
  11.             ps.executeUpdate();
  12.         } catch (SQLException e) {
  13.             e.printStackTrace();
  14.         } finally {
  15.             JdbcUtil.release(conn, ps, null);
  16.         }
  17.     }

7. 데이터베이스 연결 풀

(1. 개요

JDBC 개발 프로세스:

Ⅰ. 데이터베이스 드라이버 로드(한 번만 로드하면 됨)

Ⅱ. 데이터베이스 연결(Connection)을 설정합니다.

Ⅲ. Connection에 의해 생성된 SQL을 데이터베이스로 보내는 State 객체를 생성합니다.

Ⅴ.SQL문 작성

Ⅴ. SQL 실행(Query--&gt;ResultSet 객체가 결과 세트를 수신함)

Ⅵ. 연결을 종료하고 리소스를 해제합니다.

데이터베이스 연결 개체는 DriverManager를 통해 가져옵니다. 가져올 때마다 데이터베이스에 적용하여 연결을 얻고 사용자 이름과 비밀번호를 확인해야 합니다.

사용자는 모든 요청에 ​​대해 데이터베이스에서 링크를 얻어야 하며, 데이터베이스에 대한 연결을 생성하는 것은 일반적으로 상대적으로 많은 리소스를 소비하고 생성하는 데 오랜 시간이 걸립니다.

SQL 문이 실행될 때마다 연결이 끊겨 자원 낭비가 발생하고 데이터베이스 연결 자원이 잘 재사용되지 않는다.

웹 사이트가 하루에 100,000번의 방문을 받는다고 가정하면, 데이터베이스 서버는 100,000개의 연결을 생성해야 합니다. 이는 데이터베이스 리소스의 엄청난 낭비이며 데이터베이스 서버 메모리 오버플로 및 시스템 확장을 쉽게 유발할 수 있습니다.

솔루션: 데이터베이스 연결 풀

데이터베이스 연결 풀의 기본 아이디어:

데이터베이스에 대한 버퍼 풀을 구축하고, 미리 일정 개수의 연결 개체를 버퍼 풀에 넣어둡니다.

데이터베이스 연결을 얻으려면 버퍼 풀에서 개체를 가져오기만 하면 됩니다.

사용 후에는 다음 요청을 위해 버퍼 풀에 다시 넣어서 반복 생성 없이 리소스를 재사용할 수 있습니다.

데이터베이스 연결 풀에 유휴 연결 개체가 없으면 새 요청은 대기 대기열에 들어가 다른 스레드가 연결을 해제할 때까지 기다립니다.

(2) 용도

JDBC의 데이터베이스 연결 풀은 javax.sql.DataSource 인터페이스를 사용하여 완성됩니다. DataSource는 java에서 공식적으로 제공하는 인터페이스입니다.

이를 사용할 때 개발자는 인터페이스를 직접 구현할 필요가 없으며 타사 도구를 사용할 수 있습니다.

C3P0은 일반적으로 사용되는 타사 구현입니다. 실제 개발에서는 C3P0을 직접 사용하여 데이터베이스 연결 풀 작업을 완료할 수 있습니다.

사용 단계:

① pom.xml에서 종속성을 가져옵니다.

  1. 	<dependency>
  2. 	    <groupId>com.mchange</groupId>
  3. 	    <artifactId>c3p0</artifactId>
  4. 	    <version>0.9.5.2</version>
  5. 	</dependency>

② 코드 작성

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

알아채다:

기존 방법을 통해 얻은 연결: com.mysql.cj.jdbc.ConnectionImpl@3c153a1

C3P0에서 얻은 연결: com.mchange.v2.c3p0.impl.NewProxyConnection@6156496

그래서,모두 close 메소드를 호출하지만 구현 클래스가 다르기 때문에 메소드 재작성도 다릅니다. 이것이 인터페이스 다형성입니다.。

C3P0의 close 메소드는 연결 자원을 직접 파기하지 않고 연결을 데이터베이스 연결 풀로 반환한다.

위의 데이터베이스 연결 풀 매개변수 설정 방법은 Java 프로그램에서 직접 작성되었습니다.

이는 채택됨하드코드방법,구성을 변경할 때마다다시 컴파일해야 함, 새 클래스 파일을 생성하면 효율성이 너무 낮습니다.。

실제 개발에서는 C3P0의 구성 정보가 xml 파일에 정의되어 있으며 Java 프로그램은 구성 파일만 로드하면 데이터베이스 연결 풀의 초기화 작업이 완료됩니다.

이후에는 구성을 수정하고 다시 컴파일하지 않고 xml의 구성만 수정하면 됩니다.

사용 단계:

① 리소스 디렉터리에 c3p0-config.xml이라는 새 파일을 생성합니다.

② c3p0-config.xml에 구성 정보를 입력합니다.

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

③Java 프로그램 작성

  1. public class DataSourceTest {
  2.     public static void main(String[] args) {
  3.         try {
  4.             //创建C3P0数据库连接池
  5.             ComboPooledDataSource dataSource=new ComboPooledDataSource("C3P0Test");
  6.             Connection conn=dataSource.getConnection();
  7.             System.out.println(conn);
  8.             //将连接还回到数据库连接池中
  9.             conn.close();
  10.         }catch (SQLException e) {
  11.             e.printStackTrace();
  12.         }
  13.     }
  14. }

알아채다:

① ComboPooledDataSource 생성 방식의 파라미터는 c3p0-config.xml에 구성되어 있는 names-config 태그의 name 속성 값이다.

② 이때, JDBC 도구 클래스는 다음과 같이 수정할 수 있습니다.

  1. public class JdbcUtil {
  2.     private static DataSource dataSource;
  3.  
  4.     static {
  5.         dataSource = new ComboPooledDataSource("C3P0Test");
  6.     }
  7.  
  8.     // 获取数据库连接对象
  9.     public static Connection getConnection() throws SQLException {
  10.         Connection conn = null;
  11.         try {
  12.             conn = dataSource.getConnection();
  13.         } catch (SQLException e) {
  14.             e.printStackTrace();
  15.         }
  16.         return conn;
  17.     }
  18.  
  19.     // 释放资源（利用多态：Statement 和 PreparedStatement 都可以传进来）
  20.     public static void release(Connection conn, Statement st, ResultSet rs) {
  21.         try {
  22.             if (rs != null) {
  23.                 rs.close();
  24.             }
  25.             if (st != null) {
  26.                 st.close();
  27.             }
  28.             if (conn != null) {
  29.                 conn.close();
  30.             }
  31.         } catch (SQLException e) {
  32.             e.printStackTrace();
  33.         }
  34.     }
  35. }

8.DB유틸리티

  1.     public static Student findById(Integer idx) {
  2.         Connection conn = null;
  3.         PreparedStatement st = null;
  4.         ResultSet rs = null;
  5.         Student stu = null;
  6.         try {
  7.             conn = JdbcUtil.getConnection();
  8.  
  9.             String sql = "select * from student where id = ?";
  10.             PreparedStatement ps = conn.prepareStatement(sql);
  11.             //给占位符 ? 填充数据
  12.             ps.setInt(1, idx);
  13.             rs = ps.executeQuery();
  14.             //取出结果集的数据
  15.             while (rs.next()) {
  16.                 Integer id = rs.getInt(1);
  17.                 String name = rs.getString(2);
  18.                 Double score = rs.getDouble(3);
  19.                 Date birthday = rs.getDate(4);
  20.                 stu = new Student(id, name, score, birthday);
  21.             }
  22.         } catch (SQLException e) {
  23.             e.printStackTrace();
  24.         } finally {
  25.             try {
  26.                 //关闭链接，释放资源
  27.                 rs.close();
  28.                 st.close();
  29.                 conn.close();
  30.             } catch (SQLException e) {
  31.                 e.printStackTrace();
  32.             }
  33.         }
  34.         return stu;
  35.     }

위 코드에서는 자리 표시자를 데이터로 채우고 결과 집합에서 데이터를 추출하는 작업이 너무 번거롭습니다.

Student 테이블에 100개의 속성이 있는 경우 데이터를 검색하려면 while 루프에 100개의 행을 작성해야 하며 자리 표시자를 채우는 데에도 많은 행이 필요할 수 있습니다.

해결책:DBUtils는 개발자가 데이터 캡슐화(결과 세트를 Java 객체에 매핑)를 완료하는 데 도움이 될 수 있습니다.

사용 단계:

① pom.xml에서 종속성을 가져옵니다.

  1. <dependency>
  2. 	<groupId>commons-dbutils</groupId>
  3. 	<artifactId>commons-dbutils</artifactId>
  4. 	<version>1.6</version>
  5. </dependency>

② 코드 작성

  1.     public static Student findById(Integer idx) {
  2.         Connection conn = null;
  3.         Student stu = null;
  4.         try {
  5.             conn = JdbcUtil.getConnection();
  6.  
  7.             String sql = "select * from student where id = ?";
  8.             //使用DBUtils
  9.             QueryRunner qr = new QueryRunner();
  10.             stu = qr.query(conn, sql, new BeanHandler<>(Student.class), idx);
  11.         } catch (SQLException e) {
  12.             e.printStackTrace();
  13.         } finally {
  14.             try {
  15.                 //关闭链接，释放资源
  16.                 conn.close();
  17.             } catch (SQLException e) {
  18.                 e.printStackTrace();
  19.             }
  20.         }
  21.         return stu;
  22.     }

이 시점에서 자리 표시자를 채우고 결과 집합을 가져오는 작업은 두 줄의 코드로 수행할 수 있습니다.

세부 사항:

① 쿼리 메소드는 4개의 매개변수를 전달해야 합니다.

연결 개체

SQL 문

ResultSetHandler 인터페이스의 구현 클래스 객체(변환된 객체의 유형은 Student.class여야 함)

자리표시자를 채우는 매개변수

② ResultSetHandler 인터페이스는 조회된 결과 세트를 Java 객체로 변환하는 데 사용됩니다. 다음과 같은 4가지 구현 클래스가 제공됩니다.

빈핸들러결과 세트를 Java 객체(예: Student 객체)에 매핑합니다.
빈리스트 핸들러 결과 세트를 목록 컬렉션(예: 목록)으로 매핑합니다.<Student > )
맵 핸들러

결과 세트를 Map 컬렉션 객체에 매핑

(예: 지도<String,Object> 키: 속성 이름; 값: 속성 값)

맵리스트핸들러 결과 세트를 MapList 컬렉션으로 매핑합니다(예: List <Map<<String,Object> &gt;)

③ 자리 표시자를 채우는 매개변수는 가변 매개변수이므로 사용자의 다양한 요구를 충족시키기 위해 원하는 수의 매개변수를 전달할 수 있습니다.

④ 변환된 객체 클래스(Student 클래스)에는 매개변수가 없는 생성자가 있어야 합니다. 그렇지 않으면 프로그램에서 오류가 발생합니다.

이유:맨 아래 레이어는 Student.class를 통해 이 클래스를 찾은 다음반사 메커니즘이 클래스의 매개변수 없는 생성자를 찾아 해당 객체를 만듭니다.

⑤ 클래스의 속성 이름은 데이터베이스 테이블의 필드 이름과 정확히 동일해야 합니다.

왜냐하면 객체가 생성된 후 결과 집합을 기준으로 객체 속성에 값을 할당하면 이름을 기준으로 검색과 할당이 이루어지기 때문입니다.

11. MVC 3계층 아키텍처

MVC란 무엇입니까?

  • 모델: 모델(서비스, dao, 엔터티)
  • 보기: 보기(jsp, html, 앱 클라이언트)
  • 컨트롤러: 컨트롤러(서블릿, 핸들러, 액션)

요청이 JavaWeb 애플리케이션에 들어간 후 Controller는 요청을 수신하고 비즈니스 로직 처리를 수행한 다음 최종적으로 결과를 사용자에게 반환합니다(View + Model).

1. 소개

초기에는 웹 애플리케이션을 운영할 때 사용자가 제어 계층에 직접 접근했고, 제어 계층은 데이터베이스를 직접 운영할 수 있었습니다.

서블릿--CRUD(추가, 삭제, 수정)--&gt;데이터베이스

서블릿 코드에서: 요청, 응답, 뷰 점프 처리, JDBC 처리, 비즈니스 코드 처리, 논리 코드 처리

단점:프로그램이 너무 비대해지고 유지 관리에 도움이 되지 않습니다.

해결책: 다른 레이어를 추가해도 해결되지 않는 문제는 없습니다. 문제가 있으면 다른 레이어를 추가하세요!

2. mvc 3티어 아키텍처

모델

  • 비즈니스 처리: 비즈니스 로직(서비스)
  • 데이터 지속성 계층: CRUD(DAO 데이터 지속성 개체)

보다

  • 데이터 표시
  • 서블릿 요청(a, form, img...)을 시작하기 위한 링크를 제공합니다.

컨트롤러(서블릿)

  • 사용자의 요청 수신: (req, 요청 매개변수, 세션 정보)
  • 해당 코드를 처리하기 위해 비즈니스 계층에 넘겨줍니다.
  • 컨트롤 뷰 점프

사용자 및 관리자 로그인을 예로 들어 보겠습니다.

컨트롤러 레이어:

  1. @WebServlet("/login")
  2. public class LoginServlet extends HttpServlet {
  3.  
  4.     private LoginService loginService = new LoginServiceImpl();
  5.  
  6.     /* 处理登录的业务逻辑*/
  7.     @Override
  8.     protected void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
  9.         String username = req.getParameter("username");
  10.         String password = req.getParameter("password");
  11.         String type = req.getParameter("type");
  12.         Object object = loginService.login(username,password,type);
  13.         if(object != null){
  14.             HttpSession session = req.getSession();
  15.             switch (type){
  16.                 case "reader":
  17.                     Reader reader = (Reader) object;
  18.                     session.setAttribute("reader",reader);
  19.                     //跳转到用户的首页
  20.                     resp.sendRedirect("/book?page=1");
  21.                     break;
  22.                 case "admin":
  23.                     Admin admin = (Admin) object;
  24.                     session.setAttribute("admin",admin);
  25.                     //跳转到管理员的首页
  26.                     resp.sendRedirect("/admin?method=findAllBorrow&page=1");
  27.                     break;
  28.             }
  29.         }else{
  30.             resp.sendRedirect("login.jsp");
  31.         }
  32.     }
  33.  
  34. }

서비스 계층:

  1. public interface LoginService {
  2.     //利用多态，动态返回不同类型的对象
  3.     public Object login(String username,String password,String type);
  4. }
  1. public class LoginServiceImpl implements LoginService {
  2.  
  3.     private ReaderRepository readerRepository = new ReaderRepositoryImpl();
  4.     private AdminRepository adminRepository = new AdminRepositoryImpl();
  5.  
  6.     @Override
  7.     public Object login(String username, String password,String type) {
  8.         Object object = null;
  9.         //业务逻辑处理：根据type的值，来选择调用不同的登录方法，去查找不同的表
  10.         switch (type){
  11.             case "reader":
  12.                 object = readerRepository.login(username,password);
  13.                 break;
  14.             case "admin":
  15.                 object = adminRepository.login(username, password);
  16.                 break;
  17.         }
  18.         return object;
  19.     }
  20. }

Dao/Repository 레이어:

  1. public interface AdminRepository {
  2.     public Admin login(String username,String password);
  3. }
  1. public interface ReaderRepository {
  2.     public Reader login(String username,String password);
  3. }
  1. public class AdminRepositoryImpl implements AdminRepository {
  2.     //管理员的登录方法（和数据库交互）
  3.     @Override
  4.     public Admin login(String username, String password) {
  5.         Connection connection = JDBCTools.getConnection();
  6.         String sql = "select * from bookadmin where username = ? and password = ?";
  7.         PreparedStatement statement = null;
  8.         ResultSet resultSet = null;
  9.         Admin admin = null;
  10.         try {
  11.             statement = connection.prepareStatement(sql);
  12.             statement.setString(1,username);
  13.             statement.setString(2,password);
  14.             resultSet = statement.executeQuery();
  15.             if(resultSet.next()){
  16.                 admin = new Admin(resultSet.getInt(1),resultSet.getString(2),resultSet.getString(3));
  17.             }
  18.         } catch (SQLException e) {
  19.             e.printStackTrace();
  20.         } finally {
  21.             JDBCTools.release(connection,statement,resultSet);
  22.         }
  23.         return admin;
  24.     }
  25. }
  1. public class ReaderRepositoryImpl implements ReaderRepository {
  2.     //用户的登录方法（和数据库交互）
  3.     @Override
  4.     public Reader login(String username, String password) {
  5.         Connection connection = JDBCTools.getConnection();
  6.         String sql = "select * from reader where username = ? and password = ?";
  7.         PreparedStatement statement = null;
  8.         ResultSet resultSet = null;
  9.         Reader reader = null;
  10.         try {
  11.             statement = connection.prepareStatement(sql);
  12.             statement.setString(1,username);
  13.             statement.setString(2,password);
  14.             resultSet = statement.executeQuery();
  15.             if(resultSet.next()){
  16.                 reader = new Reader(resultSet.getInt(1),resultSet.getString(2),resultSet.getString(3),resultSet.getString(4),resultSet.getString(5),resultSet.getString(6),resultSet.getString(7));
  17.             }
  18.         } catch (SQLException e) {
  19.             e.printStackTrace();
  20.         } finally {
  21.             JDBCTools.release(connection,statement,resultSet);
  22.         }
  23.         return reader;
  24.     }
  25. }

 

개인 프로필

그는 30년 이상 기술 연구에 전념해 왔으며, java, linux, javascript, php, css 등 다양한 언어에 능숙하며, 오픈 소스 분야에 많은 공헌을 했습니다. 나중에 참조할 수 있도록 기술 개발의 일부 문제를 공유하는 개발자 문서 스테이션입니다.

내 연락처 정보

우편