updateofchangemessage.java

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

package com.onet.autobill.changemessage.db;

import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.SQLException;
import java.sql.Types;

import javax.sql.DataSource;

import org.apache.log4j.Logger;


public class UpdateOfChangeMessage {

	private static Logger logger = Logger.getLogger(UpdateOfChangeMessage.class);
	
	private DataSource dbSource;
	
	private String changeMessageUpdate = "{CALL ONET_ChannelMessage}";
	
	private String TABLENAME_SQL;
	
	public boolean changeMessageUpdate(){	
		
		Connection con = null;
		CallableStatement CS = null;
		
		try{
			con = dbSource.getConnection();
			if (con == null) {
				logger.error("数据库连接失败!");
				return false;
			}
	
			CS = con.prepareCall(changeMessageUpdate);
	
			CS.executeUpdate();
	
		}catch(Exception ex){
			logger.warn("更新消息失败!", ex);
			return false;
		} finally {
			try {
				if (CS != null)
					CS.close();
				if (con != null)
					con.close();
			} catch (Exception e) {
				logger.warn("关闭连接失败！", e);
			}
		}
		return true;
	}
	
	public String getTableName(String dateStr) throws SQLException {
		
		// 返回的表的名称
		String tableName = null;
		Connection con = null;
		CallableStatement CS = null;
		
		try{
			con = dbSource.getConnection();
			if (con == null) {
				logger.error("数据库连接失败!");
				return "";
			}
			CS = con.prepareCall(TABLENAME_SQL);
			CS.clearParameters();
			// 注册返回值
			CS.registerOutParameter(2, Types.VARCHAR);
			
			CS.setString(1, dateStr);
			
			CS.execute();
			
			tableName = CS.getString(2);
			
		}catch(SQLException ex){
			logger.warn("取表名失败!", ex);
			return "";
		} finally {
			try {
				if (con != null)
					con.close();
			} catch (Exception e) {
				logger.warn("关闭连接失败！", e);
			}
		}
		CS.close();

		return tableName;
	}	

	public DataSource getDbSource() {
		return dbSource;
	}

	public void setDbSource(DataSource dbSource) {
		this.dbSource = dbSource;
	}

	public String getTABLENAME_SQL() {
		return TABLENAME_SQL;
	}

	public void setTABLENAME_SQL(String tablename_sql) {
		TABLENAME_SQL = tablename_sql;
	}
}