routerinfodaoimpl.java.svn-base

自动导入文件到数据库,用于那些无法实时入库,定点时间入库的需求

package com.onet.autobill.dao.impl;

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

import org.springframework.jdbc.core.RowCallbackHandler;
import org.springframework.jdbc.core.support.JdbcDaoSupport;

import com.onet.autobill.dao.RouterInfoDao;
import com.onet.autobill.model.RouterObject;

public class RouterInfoDaoImpl extends JdbcDaoSupport implements RouterInfoDao {

	@Override
	public List<RouterObject> getRouterInfo() {
		final List<RouterObject> routerInfoList = new LinkedList<RouterObject>();

		String sql = "select ConfigId,ConfigName,ProductId,BusinessId,GateWayID,DestNumber,MsgContent,ServiceId,ForbidProv,"
			+ "IsReply, Priority,Disable from [OnetRouter].dbo.View_Config where Disable = 0 order by Priority";

		try {
			getJdbcTemplate().query(sql, new RowCallbackHandler() {
				public void processRow(ResultSet rs) throws SQLException {
					do {
						RouterObject routerObject = new RouterObject();
						routerObject.setConfigId(rs.getInt("ConfigId"));
						routerInfoList.add(routerObject);
					} while (rs.next());
				}
			});
		} catch (Exception e) {
			logger.error("", e);
		}
		return routerInfoList;
	}

}