java 使用策略模式操作JDBC数据库
更新时间：2017年08月18日 11:58:11 作者：woshisap
这篇文章主要介绍了java 使用策略模式操作JDBC数据库的相关资料,这里提供实例实现对JDBC数据库的操作增删改查的功能，需要的朋友可以参考下
java 使用策略模式操作JDBC数据库
1：构造一个操作数据库的工具类，可以获得连接和释放连接
public class DBUtil {
private static Connection conn = null;
static { //静态初始块
try {
Class.forName("com.mysql.jdbc.Driver");
conn = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/test", "root", "064319"); //初始化获取连接
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
}
}
/**
* 释放连接
* @param rs
* @param psmt
* @param conn
* @throws SQLException
*/
public static void closeAll(ResultSet rs, PreparedStatement psmt, Connection conn) throws SQLException {
if(rs != null) {
rs.close();
}
if(psmt != null) {
psmt.close();
}
if(conn != null) {
conn.close();
}
}
/**
* 获取连接
* @return
*/
public static Connection getConnection() {
return conn;
}
/**
* 根据表的名字来获得表的列信息
* @param tableName
*/
public static void getTableColumnInfoByTableName(String tableName) {
Connection conn = getConnection();
ResultSet rs = null;
PreparedStatement psmt = null;
String sql = "select * from " + tableName;
try {
psmt = conn.prepareStatement(sql);
rs = psmt.executeQuery();
ResultSetMetaData resultSetMetaData = rs.getMetaData();
for(int i = 1; i<= resultSetMetaData.getColumnCount(); i++) {
System.out.println(resultSetMetaData.getColumnName(i));
}
} catch (SQLException e) {
e.printStackTrace();
} finally {
try {
closeAll(rs, psmt, conn);
} catch (SQLException e) {
e.printStackTrace();
}
}
}
/**
* 根据表的名字来获得表的信息
* @param tableName
*/
public static void getTableInfoByTableName(String tableName) {
Connection conn = getConnection();
PreparedStatement psmt = null;
ResultSet rs = null;
String sql = "select * from " + tableName;
try {
psmt = conn.prepareStatement(sql);
rs = psmt.executeQuery();
while(rs.next()) {
ResultSetMetaData resultSetMetaData = rs.getMetaData();
for(int i = 1; i<= resultSetMetaData.getColumnCount(); i++) {
if(i < resultSetMetaData.getColumnCount()) {
System.out.print(rs.getObject(resultSetMetaData.getColumnName(i)) + ", ");
} else {
System.out.print(rs.getObject(resultSetMetaData.getColumnName(i)));
}
}
System.out.println();
}
} catch (SQLException e) {
e.printStackTrace();
} finally {
try {
closeAll(rs, psmt, conn);
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
2：构造一个操作数据库的BaseDao类
public class BaseDao {
/**
* 根据一些参数来保存相应的对象
* @param sql 要执行的sql语句
* @param params 为sql语句中相应的参数赋值
* @return
*/
protected boolean saveOrUpdate(String sql, Object[] params) {
Connection conn = null;
PreparedStatement psmt = null;
boolean flag = false;
conn = DBUtil.getConnection();
if(conn != null) {
try {
psmt = conn.prepareStatement(sql);
for(int i = 1; i <= params.length; i++) {
psmt.setObject(i, params[i-1]);
}
if(psmt.executeUpdate() > 0) {
flag = true;
}
} catch (SQLException e) {
e.printStackTrace();
} finally {
try {
DBUtil.closeAll(null, psmt, conn);
} catch (SQLException e) {
e.printStackTrace();
}
}
}
return flag;
}
/**
* 根据一定的参数获得某个具体的对象
* @param sql 要执行的sql语句
* @param params 为sql语句中相应的参数赋值
* @return
*/
public Object queryForObject(String sql, Object[] params, RowMapForObject rowMapForObject) {
Connection conn = null;
PreparedStatement psmt = null;
conn = DBUtil.getConnection();
Object obj = null;
ResultSet rs = null;
if(conn != null) {
try {
psmt = conn.prepareStatement(sql);
if(params != null && params.length > 0) {
for(int i = 1; i <= params.length; i++) {
psmt.setObject(i, params[i - 1]);
}
}
rs = psmt.executeQuery();
obj = rowMapForObject.rowMapForObject(rs);
} catch (SQLException e) {
e.printStackTrace();
} finally {
try {
DBUtil.closeAll(null, psmt, conn);
} catch (SQLException e) {
e.printStackTrace();
}
}
}
return obj;
}
/**
* 根据相应的参数获得查询的结果集
* @param sql
* @param params
* @return
*/
public List queryForList(String sql, Object[] params, RowMapForList rowMapForList) {
Connection conn = null;
PreparedStatement psmt = null;
conn = DBUtil.getConnection();
List list = null;
ResultSet rs = null;
if(conn != null) {
try {
psmt = conn.prepareStatement(sql);
if(params != null && params.length > 0) {
for(int i = 1; i <= params.length; i++) {
psmt.setObject(i, params[i - 1]);
}
}
rs = psmt.executeQuery(sql);
list = new ArrayList();
list = rowMapForList.rowMapForList(rs);
} catch (SQLException e) {
e.printStackTrace();
} finally {
try {
DBUtil.closeAll(null, psmt, conn);
} catch (SQLException e) {
e.printStackTrace();
}
}
}
return list;
}
}
3：新建一个StudentDao类，该类继承自BaseDao，实现对Student的管理
public class StudentDao extends BaseDao {
/**
* 保存一个Student的信息
*/
public boolean saveStudent(Student student) {
String sql = "insert into t_student(name, age) values(?, ?)";
Object[] params = new Object[]{student.getName(), student.getAge()};
return super.saveOrUpdate(sql, params);
}
/**
* 根据id获得一个Student的信息
* @param id
* @return
*/
public Student getStudentById(long id) {
String sql = "select * from t_student where id=?";
Object[] params = new Object[]{id};
return (Student)super.queryForObject(sql, params, new RowMapForObject() {
public Object rowMapForObject(ResultSet rs) {
Student student = null;
try {
if(rs != null && rs.next()) {
student = new Student();
student.setAge(rs.getInt(Student.AGE));
student.setId(rs.getLong(Student.ID));
student.setName(rs.getString(Student.NAME));
}
} catch (SQLException e) {
e.printStackTrace();
}
return student;
}
});
}
/**
* 获得所有Student的信息
* @return
*/
public List getStudentAll() {
String sql = "select * from t_student";
List list = super.queryForList(sql, null, new RowMapForList() {
@Override
public List rowMapForList(ResultSet rs) {
List list = null;
try {
if(rs != null) {
list = new ArrayList();
while(rs.next()) {
Student student = new Student();
student.setId(rs.getLong("id"));
student.setAge(rs.getInt("age"));
student.setName(rs.getString("name"));
list.add(student);
}
}
} catch(SQLException e) {
e.printStackTrace();
}
return list;
}
});
return list;
}
}
如有疑问请留言或者到本站社区交流讨论，大家共同进步，感谢阅读，希望能帮助到大家，谢谢大家对本站的支持！
相关文章
这篇文章主要介绍了Java接口中尽量避免使用数组的建议,根据实际示例展示了接口中使用数组而造成的影响程序速度的现象,需要的朋友可以参考下2015-07-07
基于自定义校验注解(controller、method、(groups)分组的使用)
这篇文章主要介绍了基于自定义校验注解(controller、method、(groups)分组的使用)，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2021-10-10
在 Java I/O 体系中，File 类是唯一代表磁盘文件本身的对象，而File 类定义了一些与平台无关的方法来操作文件，所以下面我们一起来看看 File 类有哪些操作方法吧2023-06-06
SpringCloud 搭建企业级开发框架之实现多租户多平台短信通知服务(微服务实战)
这篇文章主要介绍了SpringCloud 搭建企业级开发框架之实现多租户多平台短信通知服务,系统可以支持多家云平台提供的短信服务。这里以阿里云和腾讯云为例，集成短信通知服务，需要的朋友可以参考下2021-11-11
这篇文章主要介绍了Java常用的排序算法及代码实现,在Java开发中，对排序的应用需要熟练的掌握，这样才能够确保Java学习时候能够有扎实的基础能力。那Java有哪些排序算法呢？本文小编就来详细说说Java常见的排序算法,需要的朋友可以参考一下2022-04-04
IDEA的Mybatis Log Plugin插件配置和使用详解
这篇文章主要介绍了IDEA的Mybatis Log Plugin插件配置和使用，本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下2020-09-09
这篇文章主要介绍了IDEA如何搭建Struts2项目,文中通过图文介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧2018-02-02
本文详细介绍了使用SpringBoot、iText库、MyBatis等技术从数据库中选取数据并生成PDF文件的后端处理流程,文中通过代码介绍的非常详细,需要的朋友可以参考下2024-09-09
这篇文章主要介绍了SpringCloud微服务多应用脚手架的搭建与部署方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教2024-07-07
这篇文章主要介绍了详解spring security四种实现方式，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2020-11-11
最新评论