设为首页 加入收藏

TOP

c3p0数据库连接池实例(二)
2014-11-24 00:41:08 来源: 作者: 【 】 浏览:26
Tags:c3p0 数据库 连接 实例
ection.TRANSACTION_READ_COMMITTED); return conn; } }
SQLHelper.java文件内容如下:

/**
 * 功能:提供统一的查询、修改和插入方法
 */
package com.hh.db;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.util.ArrayList;
import java.util.List;

public class SQLHelper {
	private Connection conn = null;
	private PreparedStatement ps = null;
	private ResultSet rs = null;

	/**
	 * 数据查询
	 * @param sql语句
	 * @return 返回结果集List
	 */
	public List query(String sql) {
		if(sql.equals("") || sql == null){
			return null;
		}
		List list = new ArrayList();
		try {
			conn = C3P0ConnentionProvider.getConnection();
			ps = conn.prepareStatement(sql);
			rs = ps.executeQuery();
			ResultSetMetaData rsmd = rs.getMetaData();
			// 可以得到有多少列
			int columnNum = rsmd.getColumnCount();
			// 将数据封装到list中
			while (rs.next()) {
				Object[] objects = new Object[columnNum];
				for (int i = 0; i < objects.length; i++) {
					objects[i] = rs.getObject(i + 1);
				}
				list.add(objects);
			}
		} catch (Exception e) {
			// TODO: handle exception
			e.printStackTrace();
		}
		return list;
	}

	/**
	 * 插入、修改数据操作
	 * @param sql语句
	 * @return boolean 成功返回true,失败返回false
	 */
	public boolean update(String sql) {
		boolean b = false;
		if(sql.equals("") || sql == null){
			return b;
		}
		try {
			conn = C3P0ConnentionProvider.getConnection();
			ps = conn.prepareStatement(sql);
			int i = ps.executeUpdate();
			if (i == 1) {
				b = true;
			}
		} catch (Exception e) {
			// TODO: handle exception
			e.printStackTrace();
		}
		return b;
	}

}

 
至于Demo.java文件,可提供参考的内容如下:

/**
 * SQLHelper的测试类
 * 
 */
package com.hh.db;

import java.util.ArrayList;
import java.util.List;


public class Demo {
	
	private SQLHelper sqlHelper = new SQLHelper();
	
	/**
	 * 测试query
	 */
	/*public void testQuery(){
		String sql = "select * from crh2_station where id = 1";
		List list = sqlHelper.query(sql);
		List crh2StationList = new ArrayList();
		//对查询结果进行封装
		for (int i = 0; i < list.size(); i++) {
			Object object[] = (Object[]) list.get(i);
			Crh2Station crh2Station = new Crh2Station();
			crh2Station.setId(Integer.parseInt(object[0].toString()));
			crh2Station.setSlopeId(Integer.parseInt(object[1].toString()));
			crh2Station.setSlope(Double.parseDouble(object[2].toString()));
			crh2Station.setLength(Double.parseDouble(object[3].toString()));
			crh2Station.setEnd(Double.parseDouble(object[4].toString()));
			crh2Station.setHeight(Double.parseDouble(object[5].toString()));
			crh2StationList.add(crh2Station);
		}
		return crh2StationList;
	}*/
	
	/**
	 * 测试insert、update、delete
	 */
	/*public void testInsertOrUpdate(){
		String sql = "delete from crh2_station where id = 1";
		boolean b = sqlHelper.update(sql);
		if(b){//b为true则操作成功
			System.out.println("操作成功");
		}else{//b为false则操作失败
			System.out.println("操作失败");
		}
	}*/

}

参考资料:http://blog.csdn.net/wushangjimo/article/details/12654491




首页 上一页 1 2 下一页 尾页 2/2/2
】【打印繁体】【投稿】【收藏】 【推荐】【举报】【评论】 【关闭】 【返回顶部
分享到: 
上一篇Atitit.软件仪表盘(4)--db数据库.. 下一篇推荐给DBA的Oracle书籍

评论

帐  号: 密码: (新用户注册)
验 证 码:
表  情:
内  容: