在数据库中对数据的操作分为增删改查,但本质上可以将其划分为两种,增删改的操作直接作用于数据,会直接影响数据,而查询操作,并不会影响数据本身,只是将数据作为返回值返回。
那么,怎样进行封装呢?
再进行封装之前,我们先完成准备工作:
创建一个properties的资源文件,用于存储连接数据库的四个基本信息(用户名,
密码,url,驱动路径),可直接放置于src路径下
文件名:jdbc.properties
user=root password=123456 url=jdbc:mysql://localhost:3306/school driverClass=com.mysql.jdbc.Driver
资源文件建立好,我们就可以进行对增删改查的封装了,文章开篇说过,我们将增删改查分为两个方法进行封装,我们先进行增删改的封装。
1. 通过类加载获取一个输入流,参数填写我们刚刚创建的资源文件的名字,然后创建Properties的实例,通过load方法将资源文件读入内存,紧接着取出各个value。
2. 通过Class类的forName方法将类加载驱动,参数填写从配置文件中读取到的driverClass
3. 通过DriverManager.getConnectoin建立数据库连接
4. 获取到数据连接以后我们使用PerpareStatement完成sql语句预编译,此处的预编译语句我们在参数中提供
5. 由于使用PrepareStatement,所以我们需要实参sql的占位符进行填充,而sql语句在此时并不确定,所以占位符个数也就无法确定数量,所以此时我们在参数中提供可变个数形参。
6. 执行sql语句,此时使用execute(),此方法有一个boolean类型的值,可以以此判断操作是否成功
7. 到此处,对增删改的封装也就算差不多了,但是还有一个很重要的步骤,是什么呢?当然是资源的关闭,我们将其放置在finally块中进行,以此保证百分百关闭资源。
public void update1(String sql, Object ...args){
InputStream is = ClassLoader.getSystemClassLoader().getResourceAsStream("jdbc.properties");
Connection con = null;
PreparedStatement ps = null;
try {
Properties pros = new Properties();
pros.load(is);
String user = pros.getProperty("user");
String password = pros.getProperty("password");
String url = pros.getProperty("url");
String driverClass = pros.getProperty("driverClass");
Class.forName(driverClass);
con = DriverManager.getConnection(url, user, password);
ps = con.prepareStatement(sql);
for (int i = 0; i < args.length; i++) {
ps.setObject(i+1, args[i]);
}
ps.execute();
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
if (ps != null) {
ps.close();
}
} catch (SQLException throwables) {
throwables.printStackTrace();
}
try {
if (con != null) {
con.close();
}
} catch (SQLException throwables) {
throwables.printStackTrace();
}
try {
if (is != null) {
is.close();
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
说完增删改的封装我们接着聊对查询的封装,对于查询的封装相对于增删改会麻烦一些,在进行封装之前先创建一个与数据库中表相对应的实体类,以javabean的方式创建,一定要记得创建一个空参构造器。
public class Student {
private int id;
private String name;
private String sex;
public Student(){}
public Student(int id, String name, String sex){
this.id = id;
this.name = name;
this.sex = sex;
}
@Override
public String toString() {
return "Student{" +
"id=" + id +
", name='" + name + ''' +
", 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 String getSex() {
return sex;
}
public void setSex(String sex) {
this.sex = sex;
}
}
对查询封装的代码与增删改的代码在填充预编译sql语句的占位符那块以及之前都是相同的,所以,我就不在此赘述,直接开始接下来的步骤。
由于我们不确定需要查找的表,以及需要创建的实体类,所以在参数处使用反射(Class
1. 填充完占位符以后执行预编译sql语句,注意,此时使用executeQuery()方法,此方法会有一个ResultSet类型的返回值(结果集),我们需要拿到这个结果集。
2. 在进行下一步之前,请允许我多说两句, 因为我们的查询是围绕列(字段)展开的,但是我们此时无法确定具体的字段数量,怎么办呢,调用刚刚获取到的结果集的getmetaDate获取到ResultSetmetaData类型的metaData,接着调用metaData的getColumnCount()方法获取到当前获取到的结果集的列(字段)数。
3. 使用while循环,将结果集的next()方法作为判断条件,next()方法在结果集有下一项时,会返回true,同时将指针下移。
4. 调用运行时类clazz的newInstance()方法创建一个运行时类的对象,此方法会调用运行时类的空参构造器,若没有空参构造器会抛出异常。
5. 调用结果集rs的getObject()方法获取到当前的value值,调用metaData的getColumnLabel()方法获取到当前的字段名,之所以用这个方法,是因为这个方法获取到的是通过查询获取到的列名,也就是说可以获取到别名。
6. 使用运行时类的getDeclaredField()方法获取到我们刚才查询的字段所对应属性值,接着使用set方法将刚刚获取到的value设置给对应的属性值,需要注意的时,在使用set方法之前,先调setAccessible(true)。
7. 此时数据已经赋值给实体类的实例,将实体类的实例添加到list中,循环结束后,将list作为返回值返回
8. 关闭资源,若程序执行过程中出现异常,返回null。
publicList select1(Class clazz, String sql , Object ...args){ List list = new ArrayList<>(); InputStream is = ClassLoader.getSystemClassLoader().getResourceAsStream("jdbc.properties"); Properties pros = new Properties(); Connection con = null; PreparedStatement ps = null; ResultSet rs = null; try { pros.load(is); String user = pros.getProperty("user"); String password = pros.getProperty("password"); String url = pros.getProperty("url"); String driverClass = pros.getProperty("driverClass"); Class.forName(driverClass);//jdbc:mysql://localhost:3306/school con = DriverManager.getConnection(url, user, password); ps = con.prepareStatement(sql); for (int i = 0; i < args.length; i++) { ps.setObject(i+1, args[i]); } rs = ps.executeQuery(); ResultSetmetaData metaData = rs.getmetaData(); int columnCount = metaData.getColumnCount(); while(rs.next()){ T t = clazz.newInstance(); for (int i = 0; i < columnCount; i++) { Object columnValue = rs.getObject(i + 1); String columnLabel = metaData.getColumnLabel(i + 1); Field field = clazz.getDeclaredField(columnLabel); field.setAccessible(true); field.set(t, columnValue); } list.add(t); } return list; } catch (Exception e) { e.printStackTrace(); } finally { try { if (rs != null) { rs.close(); } } catch (SQLException throwables) { throwables.printStackTrace(); } try { if (ps != null) { ps.close(); } } catch (SQLException throwables) { throwables.printStackTrace(); } try { if (con != null) { con.close(); } } catch (SQLException throwables) { throwables.printStackTrace(); } try { if (is != null) { is.close(); } } catch (IOException e) { e.printStackTrace(); } } return null; }
今天的分享到这就结束了,感谢您的阅读。



