productdaoimpl.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.ProductDao;
import com.onet.autobill.model.LineObject;

public class ProductDaoImpl extends JdbcDaoSupport implements ProductDao {

	@Override
	public List<LineObject> getProduct() {
		final List<LineObject> productList = new LinkedList<LineObject>();

		String sql = "SELECT tn_commandId,productId, tc_msgContent, tn_contentMatchFlag, tc_destTermID, tn_termMatchFlag FROM InfocenterServer.OnetServiceExpansion.dbo.ONET_TStaticCmdInfo where tn_status = 0";

		try {
			getJdbcTemplate().query(sql, new RowCallbackHandler() {
				public void processRow(ResultSet rs) throws SQLException {
					do {
						LineObject lineObject = new LineObject();
						lineObject.setCommandId(rs.getString("tn_commandId"));
						productList.add(lineObject);
					} while (rs.next());
				}
			});
		} catch (Exception e) {
			logger.error("", e);
		}
		return productList;
	}

}