pailiebianhao.java

一个真实项目的源代码。有一个比较优秀的时间类

package com.zx.dangangl;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

import com.work.db.DbConnection;
import com.work.db.DbUtil;
import com.work.exception.OurException;

public class PaiLieBianHao {
private Log log = LogFactory.getLog(PaiLieBianHao.class);
	/**
	 * 保存件号。
	 * @param ids 需要保存的记录的id
	 * @param jhId 用户编写的件号的值
	 */
	public void saveJianHao(String[] ids,String[] jhId){
		if(ids==null || ids.length<1){			
			throw new OurException("要保存件号的记录id不能为空！");
		}
		if(jhId==null || jhId.length<1){			
			throw new OurException("要保存件号的值不能为空！");
		}		
		String sql = "update zx_jian set jh=? where id=?";

		Connection conn = DbConnection.getConn();
		if (conn == null)
			throw new OurException("获取数据库连接失败！");
		PreparedStatement pst = null;
		int LEN = ids.length;
		int tempId = 0;//处理有附件的情况，例如批复、请示也需要处理
		try {
			conn.setAutoCommit(false);
			pst = conn.prepareStatement(sql);
			for(int i=0;i<LEN;i++){
				pst.setInt(1,Integer.parseInt(jhId[i]));
				pst.setInt(2,Integer.parseInt(ids[i]));
				pst.executeUpdate();
//				String tempSql = "select id from zx_jian where sfbm="+ids[i];
//				tempId = DbUtil.getCount(tempSql);
//				if(tempId>0){
//					pst.setInt(1,Integer.parseInt(jhId[i]));
//					pst.setInt(2,tempId);
//					pst.executeUpdate();
//				}
				
			}
			
			conn.commit();
			log.info("文件编号处理成功！");
		} catch (SQLException e) {
			log.error("文件编号失败！",e);
			try {
				conn.rollback();
			} catch (SQLException e1) {
				e1.printStackTrace();
			}
			throw new OurException("文件编号失败！",e);
		} finally {
			DbUtil.closeStatement(pst);
			DbUtil.closeConnection(conn);
		}
	}
}