jdbc实现连接和增删改查功能

时间:2021-05-19

JDBC的定义

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

jdbc的基本连接

简单的说就是加载驱动,建立连接,然后进行查询和删除等语句的操作,在java中提供了java.sql的jar包,不过我现在用的是mysql的连接和实例,在这里基本在本地的服务器都是用到下面这个语句。

Class.forName("com.mysql.jdbc.Driver"); String url="jdbc:mysql://localhost:3306/test2?useUnicode=true&characterEncoding=utf-8"; String user="root"; String password="root";

加载和建立连接,这就是基本的一个语法结构,在连接数据库当然还有其他的属性可以设置,比如说最大的连接数了,和如何建立连接池,都可以在配置中用到,这里我就简单的介绍如何连接,后面跟的是这个连接的字符集,防止出现乱码。

简单的增删改查

简单的增删改查是每个开发者都会遇到的,毕竟我们整个系统真正的业务所在也是这几个简单的逻辑,但是在关系的连接和耦合性下就会变成复杂百倍的系统,所以要懂得基本的就可以窥见更大系统的构建了,所以我现在要分析的只是基本的功能实现。

首先连接好数据库之后,那就是创建查询语句,这里用到的是statment这个关键词,下面是代码的基本实现。

package dbtest;import java.sql.Connection;import java.sql.DriverManager;import java.sql.ResultSet;import java.sql.SQLException;import java.sql.Statement;import java.text.SimpleDateFormat;import java.util.ArrayList;import java.util.Date;import java.util.List;public class DbTest { public static void main(String[] args) { Employee employee1 =new Employee(); employee1.setEmpno(555); employee1.setEname("hakly"); employee1.setSal(5400); employee1.setHiredate(new Date()); addEmployee(employee1); List<Employee>employees=getEmployees(); for(Employee employee:employees){ System.out.println(employee); } Employee employee =new Employee(); employee.setEmpno(999); employee.setEname("jack"); employee.setSal(5000); employee.setHiredate(new Date()); addEmployee(employee); } public static List<Employee> getEmployees() { ResultSet rs=null; Connection conn=null; Statement stat=null; List<Employee> employees=new ArrayList<Employee>(); try{ Class.forName("com.mysql.jdbc.Driver"); String url="jdbc:mysql://localhost:3306/test2?useUnicode=true&characterEncoding=utf-8"; String user="root"; String password="root"; conn= DriverManager.getConnection(url,user,password); stat=conn.createStatement(); String sql="select * from emp"; rs=stat.executeQuery(sql); Employee employee=null; while(rs.next()){ employee=new Employee(); employee.setEmpno(rs.getInt("empno")); employee.setEname(rs.getString("ename")); employee.setSal(rs.getDouble("sal")); employee.setHiredate(rs.getDate("hiredate")); employees.add(employee); } }catch(Exception e ){ e.printStackTrace(); }finally{ try { if(conn!=null){ conn.close(); } }catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } return employees; } public static void addEmployee(Employee employee) { Connection conn = null; Statement stat = null; // 1.注册驱动程序 try { Class.forName("com.mysql.jdbc.Driver"); // 2.建立连接 String url = "jdbc:mysql://localhost:3306/test2?useUnicode=true&characterEncoding=utf-8"; String user = "root"; String password = "root"; conn = DriverManager.getConnection(url, user, password); // 3.创建执行语句,发送sql命令 stat = conn.createStatement(); SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); String sql = "insert into emp(empno,ename,sal,hiredate) values(" + employee.getEmpno() + ",'" + employee.getEname() + "'," + employee.getSal() + ",'" + sdf.format(employee.getHiredate()) + "')"; // 4.处理执行结果 int i = stat.executeUpdate(sql); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } finally { // 5.关闭资源 try { if (conn != null) { conn.close(); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } } public static void updateEmployee(Employee employee) { Connection conn = null; Statement stat = null; // 1.注册驱动程序 try { Class.forName("com.mysql.jdbc.Driver"); // 2.建立连接 String url = "jdbc:mysql://localhost:3306/test2?useUnicode=true&characterEncoding=utf-8"; String user = "root"; String password = "root"; conn = DriverManager.getConnection(url, user, password); // 3.创建执行语句,发送sql命令 stat = conn.createStatement(); SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); String sql = "update emp set ename='"+employee.getEname()+"empno"+employee.getEmpno()+"sal"+employee.getSal(); // 4.处理执行结果 int i = stat.executeUpdate(sql); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } finally { // 5.关闭资源 try { if (conn != null) { conn.close(); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } }}

这里的代码很繁琐,但是没办法,为了更清新一点的去了解,这个过程是必须的,然后接下来就是进行简单的优化,虽然代码还是差不多,但是感觉上会更加简洁了 ,这里就要建立一个工具类了代码如下

package dbtest;import java.sql.Connection;import java.sql.DriverManager;import java.sql.SQLException;public class JdbcUtil { static String url = "jdbc:mysql://localhost:3306/xxx?useUnicode=true&characterEncoding=utf-8"; static String user = "root"; static String password = "root"; static{ try { Class.forName("com.mysql.jdbc.Driver"); } catch (ClassNotFoundException e) { // TODO Auto-generated catch block e.printStackTrace(); } } public static Connection getConnection() throws SQLException{ String url = "jdbc:mysql://localhost:3306/test2?useUnicode=true&characterEncoding=utf-8"; String user = "root"; String password = "root"; return DriverManager.getConnection(url, user, password); } public static void free(Connection conn){ try { if (conn != null) { conn.close(); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } }

在这里,把数据库连接和异常处理,等工作都及合成一个工具类,然后再主函数调用就可以了,这就是面向对象的一个体现,当然还是会分析下关于主类的代码,要不然就太过于空洞了,下面要分析的主类代码如下

package com.niit.jdbc;import java.sql.Connection;import java.sql.DriverManager;import java.sql.ResultSet;import java.sql.SQLException;import java.sql.Statement;import java.text.ParseException;import java.text.SimpleDateFormat;import java.util.ArrayList;import java.util.Date;import java.util.List;public class EmployeeDao1 { public static void main(String[] args) throws ParseException { List<Employee> employees=getEmployees(); for(Employee employee:employees){ System.out.println(employee); } } public static List<Employee> getEmployees() { Connection conn = null; Statement stat = null; ResultSet rs = null; List<Employee> employees = new ArrayList<Employee>(); // 1.注册驱动程序 try { //2.获取连接 conn=JdbcUtil.getConnection(); // 3.创建执行语句,发送sql命令 stat = conn.createStatement(); String sql = "select * from emp"; // 4.处理执行结果 rs = stat.executeQuery(sql); Employee employee = null; while (rs.next()) { employee = new Employee(); employee.setEmpno(rs.getInt("empno")); employee.setEname(rs.getString("ename")); employee.setSal(rs.getDouble("sal")); employee.setHiredate(rs.getDate("hiredate")); employees.add(employee); } } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } finally { // 5.关闭资源 JdbcUtil.free(conn); } return employees; } public static void addEmployee(Employee employee) { Connection conn = null; Statement stat = null; // 1.注册驱动程序 try { //2.获取连接 conn=JdbcUtil.getConnection(); // 3.创建执行语句,发送sql命令 stat = conn.createStatement(); SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); String sql = "insert into emp(empno,ename,sal,hiredate) values(" + employee.getEmpno() + ",'" + employee.getEname() + "'," + employee.getSal() + ",'" + sdf.format(employee.getHiredate()) + "')"; // 4.处理执行结果 int i = stat.executeUpdate(sql); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } finally { // 5.关闭资源 JdbcUtil.free(conn); } } public static void updateEmployee(Employee employee) { Connection conn = null; Statement stat = null; // 1.注册驱动程序 try { //2.获取连接 conn=JdbcUtil.getConnection(); // 3.创建执行语句,发送sql命令 stat = conn.createStatement(); SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); String sql = "update emp set ename='" + employee.getEname() + "',sal=" + employee.getSal() + ",hiredate='" + sdf.format(employee.getHiredate()) + "' where empno=" + employee.getEmpno(); // 4.处理执行结果 int i = stat.executeUpdate(sql); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } finally { // 5.关闭资源 JdbcUtil.free(conn); } } public static void deleteEmployee(int empno) { Connection conn = null; Statement stat = null; // 1.注册驱动程序 try { //2.获取连接 conn=JdbcUtil.getConnection(); // 3.创建执行语句,发送sql命令 stat = conn.createStatement(); SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); String sql = "delete from emp where empno="+empno; // 4.处理执行结果 int i = stat.executeUpdate(sql); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } finally { // 5.关闭资源 JdbcUtil.free(conn); } }}

这样看上去就比较清晰和明了,不用分割开来去看代码,只要调用到那个累才去照这个类的方法,这样就能够更加有利于检查和排错,维护的间接性的一个软件的奋斗的目标,虽然只是简单的优化,却能够减轻了我们写代码和维护的成本。

总结

通过本次编码,对面向对象的编程的开发有更加清晰的了解,当然对重构和优化的重要性有更深的了解,在这个软件里我学会的不仅是代码的书写,还学会了代码的重构不仅需要不断的提炼,还需要对代码的细微的观察。

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。

声明:本页内容来源网络,仅供用户参考;我单位不保证亦不表示资料全面及准确无误,也不保证亦不表示这些资料为最新信息,如因任何原因,本网内容或者用户因倚赖本网内容造成任何损失或损害,我单位将不会负任何法律责任。如涉及版权问题,请提交至online#300.cn邮箱联系删除。

相关文章