用jdbc写sql层的时候diy了一个DAL类,将一些常用的sql操作(增,删,查,改)写在了一个静态类里面,形成了一个简单的sql操作工具类,在DAO层要用到sql操作的时候直接调用类的静态方法使用就行了,同时配了数据源,此例子是使用了proxool数据源,及一些简单的数据动态配置:
代码如下:
package com.db;
//数据库访问层
import java.io.BufferedInputStream;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.Properties;
import javax.sql.RowSet;
import javax.sql.rowset.CachedRowSet;
import org.apache.log4j.Logger;
import com.sun.rowset.CachedRowSetImpl;
public class DAL
{
private static Logger log = Logger.getLogger(DAL.class);
private static String dburl = null;
private static boolean inited = false;
/**
* 得到一个已联接好的数据库联连 一般用于过程执行
*
* @return
*/
public static Connection getConn()
{
try
{
// 使用连接池
if (inited)
{
return DriverManager.getConnection("proxool.city");
}
if (dburl == null)
{
InputStream in = new BufferedInputStream(DAL.class.getResourceAsStream("db.pro"));
Properties p = new Properties();
p.load(in);
dburl = p.getProperty("mysqlurl");
log.debug(dburl);
}
Class.forName("org.logicalcobwebs.proxool.ProxoolDriver");
Connection conn = DriverManager.getConnection("proxool.city:com.mysql.jdbc.Driver:" + dburl);
inited = true;
return conn;
}
catch (Exception e)
{
e.printStackTrace();
}
return null;
}
/**
* 对数据库执行查询方法
*
* @param sql
* @return
*/
public static RowSet query(String sql)
{
Connection conn = getConn();
ResultSet rs;
try
{
Statement s = conn.createStatement();
log.debug(sql);
rs = s.executeQuery(sql);
CachedRowSet crs = new CachedRowSetImpl();
crs.populate(rs);
conn.close();
return crs;
}
catch (Exception e)
{
e.printStackTrace();
}
return null;
}
/**
* 对数据库执行更新打操作
*
* @param sql
* @return
*/
public static int exec(String sql)
{
Connection conn = getConn();
int rt;
try
{
log.debug(sql);
Statement s = conn.createStatement();
rt = s.executeUpdate(sql);
conn.close();
return rt;
}
catch (Exception e)
{
e.printStackTrace();
}
return 0;
}
/**
* 对数据库进行添加操作
*
* @param sql
* @return
*/
public static int add(String sql)
{
Connection conn = getConn();
int rt;
try
{
log.debug(sql);
Statement s = conn.createStatement();
rt = s.executeUpdate(sql);
conn.close();
return rt;
}
catch (Exception e)
{
e.printStackTrace();
}
return 0;
}
/**
* 对数据库进行删除操作
*
* @param sql
* @return
*/
public static int del(String sql)
{
Connection conn = getConn();
int rt;
try
{
log.debug(sql);
Statement s = conn.createStatement();
rt = s.executeUpdate(sql);
conn.close();
return rt;
}
catch (Exception e)
{
e.printStackTrace();
}
return 0;
}
//测试数据库连接
public static void main(String args[])throws Exception{
System.out.println("得到一个数据连接 "+getConn()) ;
}
}
分享到:
相关推荐
斑马介绍Zebra是一个基于JDBC API协议的上开发出的高可用,高性能的数据库访问层解决方案,是美团评论内部使用的数据库访问层中间件。具有以下功能点:配置集中管理,动态刷新支持读写分离,分库分表丰富的监控信息...
如果"pets-master"包含了Spring的相关代码,那么我们可能会看到IoC(Inversion of Control)容器、AOP(面向切面编程)、Spring MVC以及数据访问层的集成,如JDBC或Spring Data JPA。 4. **数据库交互**:为了存储...
4. **数据访问**:Spring提供JDBC抽象层,简化了数据库操作,同时支持ORM(对象关系映射)框架,如Hibernate和MyBatis,方便与数据库交互。 5. **事务管理**:Spring提供了声明式事务管理,开发者只需在配置文件或...
总结,Spring 4.3.0版本是一个强大的企业级框架,它在依赖注入、AOP、数据访问、Web开发等多个方面都有出色的表现。通过深入研究其源码,不仅可以提升对Spring的理解,还能为实际项目开发带来宝贵的洞见。对于任何...
4. **数据访问**:Spring提供了JDBC抽象层,简化了数据库操作,减少了错误。此外,它还支持多种ORM(Object-Relational Mapping,对象关系映射)框架,如Hibernate和MyBatis,让数据库操作更加方便。 5. **MVC框架*...