java技术案例--封装JDBC工具类

  1. 云栖社区>
  2. 博客>
  3. 正文

java技术案例--封装JDBC工具类

千锋教育_Mr.chen 2019-11-22 15:15:31 浏览4304

JDBC简介
- JDBC(Java DataBase Connectivity,java数据库连接)是一种用于执行SQL语句的Java API,可以为多种关系数据库提供统一访问,它由一组用Java语言编写的类和接口组成。JDBC提供了一种基准,据此可以构建更高级的工具和接口,使数据库开发人员能够编写数据库应用程序

- Java 具有坚固、安全、易于使用、易于理解和可从网络上自动下载等特性,是编写数据库应用程序的杰出语言。所需要的只是 Java应用程序与各种不同数据库之间进行对话的方法。

- JDBC可以在各种平台上使用Java,如Windows,Mac OS和各种版本的UNIX。

- JDBC库包括通常与数据库使用相关的下面提到的每个任务的API。

JDBC实现验证登录代码思路
 * 键盘输入用户名和密码,对比数据库中的用户信息,判断是否登录成功
 *     1、连接数据库

 *         MyJDBCUtils.getConnection()

 *     2、获取请求对象stmt

 *         conn.createStmtement()

*     3、创建键盘对象,获取用户名和密码

*         3.1    创建键盘录入对象

*         3.2    提示用户输入

*         3.3    获取用户输入内容

*     4、编写SQL语句,把用户名和密码放入SQL语句中

*     5、执行查询,获取查询结果

*         stmt.executeQuery(sql);

*     6、根据查询结果判断登录是否成功
*     7、关闭连接

Java工具类
在java开发过程中,代码中时常用到一些Scanner、Random一样的类,他们是键盘录入,生成随机数的类,像一个工具一样,在java中被称为工具类。

         我们在编写自己的代码时,有的代码功能和java工具类似,比如连接数据库、验证登录,时长会用得到,每次都书写一次太麻烦,我们可以尝试编写自己的工具类,每次用到的时候直接导包调用就行,能提高我们的开发效率。

封装JDBC工具类
加入获取数据库连接对象的方法
加入释放连接的方法
代码如下:

工具类代码:

package com.qianfeng.util;

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Statement;

/**

 * JDBC工具类

 * 有获取连接的方法

 * @author dushine

 */

public class JDBCUtil {

        

         /**

          * 获取数据库连接的方法

          * @return Connection conn

          * @throws SQLException

          */

         public static Connection getConnection() throws SQLException {

                   String url = "jdbc:mysql://localhost:3306/class?useSSL=false";

                   String user = "root";

                   String password = "root";

                   Connection conn = DriverManager.getConnection(url,user,password);

                   return conn;

         }

        

         /**

          * 释放连接的方法

          * @param conn

          * @throws SQLException

          */

         public static void releaseSourse(Connection conn) throws SQLException {

                   if (conn != null) {

                            conn.close();

                   }

         }

        

        

         /**

          * 释放连接的方法

          * @param conn               数据库连接对象

          * @param stmt               执行SQL语句的对象

          * @throws SQLException

          */

         public static void releaseSourse(Connection conn,Statement stmt) throws SQLException {

                   if (stmt != null) {

                            stmt.close();

                   }

                  

                   if (conn != null) {

                            conn.close();

                   }

         }

        

         /**

          * 释放连接的方法

          * @param conn               数据库连接对象

          * @param stmt               执行SQL语句的对象

          * @param resultSet       执行SQL语句的返回的结果集

          * @throws SQLException

          */

         public static void releaseSourse(Connection conn,Statement stmt,ResultSet resultSet) throws SQLException {

                   if (resultSet != null) {

                            resultSet.close();

                   }

                  

                   if (stmt != null) {

                            stmt.close();

                   }

                  

                   if (conn != null) {

                            conn.close();

                   }

         }

}

测试类代码:

package com.qianfeng.demos;

import java.sql.Connection;

import java.sql.ResultSet;

import java.sql.Statement;

import java.util.Scanner;

import com.qianfeng.util.JDBCUtil;

public class Demo04 {

         public static void main(String[] args) throws Exception {

                   /**

                    * 登录注册

                    *   获取用户输入内容

                    *   把输入的内容当做条件查询数据库中的内容

                    */

                   Scanner sc = new Scanner(System.in);

                  

                   System.out.println("请输入用户名:");

                   String name = sc.nextLine();

                  

                   System.out.println("请输入密码:");

                   String pwd = sc.nextLine();

                  

                   // 注册驱动

                   Class.forName("com.mysql.jdbc.Driver");

                   /*

                   String url = "jdbc:mysql://localhost:3306/class?useSSL=false";

                   String user = "root";

                   String password = "root";

                   // 获取和数据库的连接

                   Connection conn = DriverManager.getConnection(url, user, password);*/

                  

                   Connection conn = JDBCUtil.getConnection();

                  

                   // 使用连接对象获取执行sql的对象

                   Statement stmt = conn.createStatement();

                  

                   // 编写SQL语句

                   String sql = "select * from userinfo where username='"+name+"' and password='"+pwd+"'";

                   System.out.println(sql);

                  

                   // 执行SQL语句,获取返回结果

                   ResultSet resultSet = stmt.executeQuery(sql);

                   if (resultSet.next()) {

                            System.out.println("登陆成功!");

                   } else {

                            System.out.println("用户名或密码错误!");

                   }

                   JDBCUtil.releaseSourse(conn, stmt, resultSet);

                   sc.close();

         }

}