package com.szpg.db.dao.impl;

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

import org.apache.commons.dbutils.DbUtils;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.BeanListHandler;
import org.apache.log4j.Logger;

import com.szpg.db.dao.PgAcuDao;
import com.szpg.db.data.PgAcu;
import com.szpg.db.util.ConnectionManager;

public class PgAcuDaoImpl implements PgAcuDao {
	
	private final Logger logger = Logger.getLogger(this.getClass().getName());

	@Override
	public List<PgAcu> findAllACU() {
		Connection conn = null;
		
		String queryStr = "SELECT * FROM PG_ACU ORDER BY ID";
		try {
			conn = ConnectionManager.getConnectionFromC3P0();
			conn.setAutoCommit(false);
			
			QueryRunner runner = new QueryRunner();
			List<PgAcu> list = (List<PgAcu>) runner.query(conn, queryStr, new BeanListHandler<PgAcu>(PgAcu.class));
			
			if (null != list && list.isEmpty() == false) {
				logger.debug("查询所有ACU成功[" + list.size() + "]");
				
				return list;
			}
			else 
				return null;
		} catch (Exception ex) {
			logger.error("查询所有ACU异常", ex);
		} finally {
			try {
				DbUtils.commitAndClose(conn);
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
		return null;
	}

}