使用dbcp连接池+sqlite

尊重版权：本文绝大部分来自：http://blog.chinaunix.net/uid-11121450-id-3129713.html

1、准备并导入jar包

commons-pool.jar
commons-dbcp.jar
sqlite-jdbc-3.7.2.jar

其在maven中配置文件为：

<dependency>
<groupId>org.xerial</groupId>
<artifactId>sqlite-jdbc</artifactId>
<version>3.7.2</version>

</dependency>

2、几个基本操作

其基本思路如下：

（1）获得datasource

（2）根据datasource获得connection

（3）根据connection获得statement或者根据connection+sql语句获得preparedStatement

（4）执行statement+sql或者preparedStatement得到返回结果resultSet

（5）根据ResultSet得到需要的返回值

（6）关闭ResultSet

（7）关闭statement或者preparedStatement

（8）关闭Connection

注意：所有关于设置数据库属性的操作全部在connection上，比如设置自动回滚

package com.search.util;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.sqlException;
import java.sql.Statement;
import org.apache.commons.dbcp.BasicDataSource;
/**
* 连接和使用数据库资源的工具类
*/
public class DatabasesqliteUtil {
/**
* 数据源
*/
private BasicDataSource dataSource;
/**
* 数据库连接
*/
public Connection conn;
/**
* 获取数据源
* @return 数据源
*/
public BasicDataSource getDataSource() {
return dataSource;
}
/**
* 设置数据源
* @param dataSource 数据源
*/
public void setDataSource(BasicDataSource dataSource) {
this.dataSource = dataSource;
}
/**
* 获取数据库连接
* @return conn
*/
public Connection getConnection() {
try {
conn = dataSource.getConnection();
} catch (Exception e) {
e.printStackTrace();
return null;
}
return conn;
}
/**
* 关闭数据库连接
* @param conn
*/
public static void closeConnection(Connection conn) {
if (null != conn) {
try {
conn.close();
conn = null;
} catch (sqlException e) {
e.printStackTrace();
}
}
}
/**
* 获取执行sql的工具
* @param conn 数据库连接
* @return stmt
*/
public static int getFoundRows(Connection conn) {
Statement stmt=null;
ResultSet rs=null;
try {
stmt=getStatement(conn);
rs=stmt.executeQuery("SELECT FOUND_ROWS()");
if(rs.next()){
return rs.getInt(1);
}
} catch (sqlException e) {
e.printStackTrace();
}finally{
closeStatement(stmt);
closeResultSet(rs);
}
return 0;
}
/**
* 获取执行sql的工具
* @param conn 数据库连接
* @return stmt
*/
public static Statement getStatement(Connection conn) {
Statement stmt = null;
try {
stmt = conn.createStatement();
} catch (sqlException e) {
e.printStackTrace();
}
return stmt;
}
/**
* 获取执行sql的工具
* @param conn 数据库连接
* @param sql sql语句
* @return prepStmt
*/
public static PreparedStatement getPrepStatement(Connection conn,String sql) {
PreparedStatement prepStmt = null;
try {
prepStmt = conn.prepareStatement(sql);
} catch (sqlException e) {
e.printStackTrace();
}
return prepStmt;
}
/**
* 关闭数据库资源
* @param stmt
*/
public static void closeStatement(Statement stmt) {
if (null != stmt) {
try {
stmt.close();
stmt = null;
} catch (sqlException e) {
e.printStackTrace();
}
}
}
/**
* 关闭数据库资源
* @param prepStmt
*/
public static void closePrepStatement(PreparedStatement prepStmt) {
if (null != prepStmt) {
try {
prepStmt.close();
prepStmt = null;
} catch (sqlException e) {
e.printStackTrace();
}
}
}
/**
* 获取结果集
* @param stmt 执行sql的工具
* @param sql sql语句
* @return 结果集
*/
public static ResultSet getResultSet(Statement stmt,String sql) {
ResultSet rs = null;
try {
rs = stmt.executeQuery(sql);
} catch (sqlException e) {
e.printStackTrace();
}
return rs;
}
/**
* 关闭数据库资源
* @param rs
*/
public static void closeResultSet(ResultSet rs) {
if (null != rs) {
try {
rs.close();
rs = null;
} catch (sqlException e) {
e.printStackTrace();
}
}
}
public static Boolean setAutoCommit(Connection conn,boolean commitStatus){
if(conn==null){
return true;
}
try {
conn.setAutoCommit(commitStatus);
boolean commit = conn.getAutoCommit();
return commit;
} catch (sqlException e1) {
e1.printStackTrace();
return true;
}
}
public static boolean rollback(Connection conn,boolean oldCommitStatus){
if(conn==null){
return true;
}
try {
conn.setAutoCommit(oldCommitStatus);
conn.rollback(); // 事物回滚
return true;
} catch (sqlException e1) {
e1.printStackTrace();
return false;
}
}
public static boolean commit(Connection conn,boolean oldCommitStatus){
if(conn==null){
return true;
}
try {
conn.setAutoCommit(oldCommitStatus);
conn.commit(); // 事物提交
return true;
} catch (sqlException e1) {
e1.printStackTrace();
return false;
}
}
public static int getLastId(PreparedStatement ps){
ResultSet rs=null;
try {
rs = ps.getGeneratedKeys();
if (rs != null&&rs.next()) {
return rs.getInt(1);
}
} catch (sqlException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}finally{
closeResultSet(rs);
}
return -1;
}
/**
* 判断是否是管理员
* @param conn MysqL连接
* @param ip 请求ip
* @param password 管理员密码
* @author yaofuyuan
* @since 2011-08-02 12:58:00
* @return void 0：不是,1:是,-1:数据库出错
*/
public int isSuperAdmin(Connection conn,String ip,String password){
if(conn==null){
return -1;
}
PreparedStatement ps =getPrepStatement(
conn,
"select count(*) as count from auth_admin_server where ip=? and password=?");
ResultSet rs = null;
try {
// 查询帐号，用户名和密码
ps.setString(1,ip);
ps.setString(2,password);
rs=ps.executeQuery();
if (rs.next()) {
if(rs.getInt("count")==0){
//用户名密码错误
return 0;
}else{
return 1;
}
}
return -1;
}
catch(Exception e){
e.printStackTrace();
return -1;
}finally{
closeResultSet(rs);
closePrepStatement(ps);
}
}
public int test(Connection conn){
PreparedStatement pst =getPrepStatement(conn,"select 123");
// 获取结果集
ResultSet rs = null;
try {
rs = pst.executeQuery();
if (rs.next()) {
return rs.getInt(1);
}
} catch (sqlException e) {
e.printStackTrace();
} finally {
// 关闭数据库资源
closeResultSet(rs);
closePrepStatement(pst);
}
return -1;
}
}

关于datasource如何配置请参看上一篇文章，谢谢原文链接：/sqlite/201397.html

使用dbcp连接池+sqlite

猜你在找的Sqlite相关文章