src/com/demo/dao/impl/CategoryDaoImpl.java

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

package com.demo.dao.impl;

import java.sql.SQLException;
import java.util.List;

import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.BeanHandler;
import org.apache.commons.dbutils.handlers.BeanListHandler;

import com.demo.utils.JdbcUtils;
import com.demo.dao.CategoryDao;
import com.demo.model.Category;

/**
 * dao层实现-对数据库：分类表的操作
 * @author shao
 */
public class CategoryDaoImpl implements CategoryDao {
	
	/** (non-Javadoc)
	 * @see com.demo.dao.CategoryDao#add(com.demo.model.Category)
	 */
	@Override
	public void add(Category category){
		try{
			QueryRunner runner = new QueryRunner(JdbcUtils.getDataSource());// JDBC的调用者，数据库操作类，DBUtils工具，参数为c3p0连接池
			String sql = "insert into category(id,name,description) values(?,?,?)";// SQL语句
			Object params[] = {category.getId(), category.getName()
					, category.getDescription()};// 多个参数封装为对象数组
			runner.update(sql, params);// 执行SQL语句
		} catch(Exception e){
			e.printStackTrace();
			throw new RuntimeException(e);
		}
	}
	
	/** (non-Javadoc)
	 * @see com.demo.dao.CategoryDao#find(java.lang.String)
	 */
	@Override
	public Category find(String id){
		try {
			QueryRunner runner = new QueryRunner(JdbcUtils.getDataSource());// JDBC的调用者，数据库操作类，DBUtils工具，参数为c3p0连接池
			String sql = "select * from category where id=?";// SQL语句
			return (Category)runner.query(sql, id, new BeanHandler(Category.class));// 执行SQL语句，并使用BeanHandler工具将结果转为POJO对象
		} catch (SQLException e) {			
			e.printStackTrace();
			throw new RuntimeException(e); 
		}
	}
	
	/** (non-Javadoc)
	 * @see com.demo.dao.CategoryDao#getAll()
	 */
	@Override
	public List<Category> getAll(){
		try {
			QueryRunner runner = new QueryRunner(JdbcUtils.getDataSource());// JDBC的调用者，数据库操作类，DBUtils工具，参数为c3p0连接池
			String sql = "select * from category";// SQL语句
			return (List<Category>)runner.query(sql, new BeanListHandler(Category.class));// 执行SQL语句，并使用BeanListHandler工具将结果转为List<POJO>对象