lbinsert.java

功能是公安和学校的管理系统,用struts+hibernate+spring等匡架组成,在eclepse就能编译

package com.comingnet.cgmanage;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import com.opensymphony.xwork2.ActionSupport;
import com.db.*;
public class LBinsert extends ActionSupport {
	private static final long serialVersionUID = 7421208062693382018L;

	private String xnd = "";

	private String xq = "";

	private String bjnj = "";

	private int njid = 0;

	private int bjid = 0;

	private String kslb = "";

	private int xxbh = 0;

	private String kssj = "";

	private String jssj = "";

	private String ksmc = "";

	private int ksxz = 0;

	private int njlist = 0;

	public String getBjnj() {
		return bjnj;
	}

	public void setBjnj(String bjnj) {
		this.bjnj = bjnj;
	}

	public String getJssj() {
		return jssj;
	}

	public void setJssj(String jssj) {
		this.jssj = jssj;
	}

	public String getKslb() {
		return kslb;
	}

	public void setKslb(String kslb) {
		this.kslb = kslb;
	}

	public String getKssj() {
		return kssj;
	}

	public void setKssj(String kssj) {
		this.kssj = kssj;
	}

	public int getNjid() {
		return njid;
	}

	public void setNjid(int njid) {
		this.njid = njid;
	}

	public String getXnd() {
		return xnd;
	}

	public void setXnd(String xnd) {
		this.xnd = xnd;
	}

	public String getXq() {
		return xq;
	}

	public void setXq(String xq) {
		this.xq = xq;
	}

	public int getXxbh() {
		return xxbh;
	}

	public void setXxbh(int xxbh) {
		this.xxbh = xxbh;
	}

	public int getKsxz() {
		return ksxz;
	}

	public void setKsxz(int ksxz) {
		this.ksxz = ksxz;
	}

	public int getNjlist() {
		return njlist;
	}

	public void setNjlist(int njlist) {
		this.njlist = njlist;
	}

	public int getBjid() {
		return bjid;
	}

	public void setBjid(int bjid) {
		this.bjid = bjid;
	}

	private void setksmc() {
		ksmc = xnd + "学年" + xq + kslb;
	}

	@Override
	public String execute() {
		setksmc();
		String flag = SUCCESS;

		Connection conn = null;
		PreparedStatement stmt = null;
		ResultSet rs = null;
		
		// 处理班级考试
		if (ksxz == 2) {
			System.out.println("处理班级考试开始");
			try {
				conn = ProxoolAction.getConnection();
				stmt = conn
						.prepareStatement("select * from cg_cglbb where bjmc='"
								+ bjnj + "' and ksmc='" + ksmc + "' and xxbh="
								+ xxbh + " and ksxz='班级考试'");
				rs = stmt.executeQuery();
				while(rs.next()) {
					flag = ERROR;
					System.out.println(rs + "2");
					break;
				}
			} catch (Exception e) {
				System.out.println(e.getMessage());
				flag = ERROR;
			} finally {
				ProxoolAction.closeResultSet(rs);
				ProxoolAction.closeStatement(stmt);
			}
			if (flag.equals(ERROR)) {
				ProxoolAction.closeConnection(conn);
				return flag;
			}

			try {
				stmt = conn
						.prepareStatement("select bjnj from m_class where bjmc='"
								+ bjnj + "' and xxbh=" + xxbh);
				rs = stmt.executeQuery();
				while (rs.next()) 
					njid = rs.getInt(1);
			} catch (SQLException e) {
				System.out.println("得到年级ID错误" + e.toString());
				flag = ERROR;
			} finally {
				ProxoolAction.closeResultSet(rs);
				ProxoolAction.closeStatement(stmt);

			}
			if (flag.equals(ERROR)) {
				ProxoolAction.closeConnection(conn);
				return flag;
			}
			PreparedStatement stmt1 = null;
			try {
				int lbxsid = 0;
				stmt1 = conn
						.prepareStatement("select distinct lbxsid from cg_cglbb where ksxz='班级考试' and ksmc='"
								+ ksmc + "' and xxbh=" + xxbh);
				rs = stmt1.executeQuery();
				if(rs.next()) {
					lbxsid = rs.getInt(1);
					ProxoolAction.closeResultSet(rs);
					ProxoolAction.closeStatement(stmt1);
				} else {
					lbxsid = KeyGenerator.getInstance().getNextKey("cg_lbxs");
					stmt = conn
							.prepareStatement("insert into cg_lbxs(LBXSID,XXBH) values(?,?)");
					stmt.setInt(1, lbxsid);
					stmt.setInt(2, xxbh);
					stmt.executeUpdate();
					ProxoolAction.closeStatement(stmt);
				}
				String sqlstr = "insert into cg_cglbb(LBID,XXBH,XND,XQ,NJ,KSXZ,BJMC,KSLB,KSMC,KSKSSJ,KSJSSJ,LBXSID) values(?,?,?,?,?,?,?,?,?,?,?,?)";
				int lbid = KeyGenerator.getInstance().getNextKey("cg_cglbb");
				stmt = conn.prepareStatement(sqlstr);
				stmt.setInt(1, lbid);
				stmt.setInt(2, xxbh);
				stmt.setString(3, xnd);
				stmt.setString(4, xq);
				stmt.setInt(5, njid);
				stmt.setString(6, "班级考试");
				stmt.setString(7, bjnj);
				//stmt.setInt(8, bjid);
				stmt.setString(8, kslb);
				stmt.setString(9, ksmc);
				stmt.setString(10, kssj);
				stmt.setString(11, jssj);
				stmt.setInt(12, lbxsid);
				stmt.executeUpdate();
			} catch (SQLException e) {
				System.out.println("成绩类别插入错误" + e.toString());
				flag = ERROR;
			} catch (KeyGenException e) {
				System.out.println(e.toString());
				flag = ERROR;
			} finally {
				ProxoolAction.closeStatement(stmt);
				ProxoolAction.closeConnection(conn);
			}
			System.out.println("处理班级考试结束");
		}else
		if (ksxz == 0) {
			System.out.println("处理全校考试开始");
			String bjmc = "";
			int njid = 0;
			PreparedStatement stmt1 = null;
			try {
				conn = ProxoolAction.getConnection();
				stmt = conn
						.prepareStatement("select * from cg_cglbb where ksxz='全校考试' and ksmc='"
								+ ksmc + "' and xxbh=" + xxbh);
				rs = stmt.executeQuery();
				if (rs.next())
					flag = ERROR;
			} catch (Exception e) {
				System.out.println(e.toString()+"异常");
				flag = ERROR;
			} finally {
				ProxoolAction.closeResultSet(rs);
				ProxoolAction.closeStatement(stmt);
			}
			if (flag.equals(ERROR)) {
				ProxoolAction.closeConnection(conn);
				return flag;
			}
			try {
				
				int lbxsid = KeyGenerator.getInstance().getNextKey("cg_lbxs");

				stmt = conn
						.prepareStatement("insert into cg_lbxs(LBXSID,XXBH) values(?,?)");
				stmt.setInt(1, lbxsid);
				stmt.setInt(2, xxbh);
				stmt.executeUpdate();
				ProxoolAction.closeStatement(stmt);
				stmt = conn
						.prepareStatement("select bjmc,bjnj from m_class where xxbh="
								+ xxbh);
				rs = stmt.executeQuery();
				while (rs.next()){
					bjmc = rs.getString(1);
					njid = rs.getInt(2);
					stmt1 = conn
					.prepareStatement("insert into cg_cglbb(LBID,XXBH,XND,XQ,NJ,KSXZ,BJMC,KSLB,KSMC,KSKSSJ,KSJSSJ,LBXSID) values(?,?,?,?,?,?,?,?,?,?,?,?)");
					try {
						int lbid = KeyGenerator.getInstance().getNextKey(
								"cg_cglbb");
						stmt1.setInt(1, lbid);
						stmt1.setInt(2, xxbh);
						stmt1.setString(3, xnd);
						stmt1.setString(4, xq);
						stmt1.setInt(5, njid);
						stmt1.setString(6, "全校考试");
						stmt1.setString(7, bjmc);
						//stmt1.setInt(8, bjid);
						stmt1.setString(8, kslb);
						stmt1.setString(9, ksmc);
						stmt1.setString(10, kssj);
						stmt1.setString(11, jssj);
						stmt1.setInt(12, lbxsid);
						stmt1.executeUpdate();
					} catch (Exception e) {
						System.out.println(e.toString()+"异常1");
						flag = ERROR;
					} finally {
						ProxoolAction.closeStatement(stmt1);
					}
				}
			} catch (Exception e) {
				System.out.println(e.getMessage()+"异常2");
				flag = ERROR;
			} finally {
				ProxoolAction.closeResultSet(rs);
				ProxoolAction.closeStatement(stmt);
				ProxoolAction.closeConnection(conn);
			}
			System.out.println("处理全校考试结束");
		}else
		if (ksxz == 1) {
			System.out.println("处理年级考试开始");
			System.out.println("年级"+njlist);
			try {
				conn = ProxoolAction.getConnection();
				stmt = conn.prepareStatement("select * from cg_cglbb where nj="
						+ njlist + " and ksmc='" + ksmc + "' and xxbh=" + xxbh
						+ " and ksxz='年级考试'");
				rs = stmt.executeQuery();
				if (rs.next())
					flag = ERROR;
			} catch (Exception e) {
				System.out.println(e.getMessage());
				flag = ERROR;
			} finally {
				ProxoolAction.closeResultSet(rs);
				ProxoolAction.closeStatement(stmt);
			}
			if (flag.equals(ERROR)) {
				ProxoolAction.closeConnection(conn);
				return flag;
			}
			PreparedStatement stmt1 = null;
			try {
				String bjmc = "";
				int lbxsid = 0;
				stmt = conn
						.prepareStatement("select distinct lbxsid from cg_cglbb where KSXZ='年级考试' and ksmc='"
								+ ksmc + "' and xxbh=" + xxbh);
				rs = stmt.executeQuery();
				if (rs.next()) {
					lbxsid = rs.getInt(1);
					
				} else {
					lbxsid = KeyGenerator.getInstance().getNextKey("cg_lbxs");
					stmt1 = conn
							.prepareStatement("insert into cg_lbxs(LBXSID,XXBH) values(?,?)");
					stmt1.setInt(1, lbxsid);
					stmt1.setInt(2, xxbh);
					stmt1.executeUpdate();
					ProxoolAction.closeStatement(stmt1);
				}
				ProxoolAction.closeResultSet(rs);
				ProxoolAction.closeStatement(stmt);

				stmt = conn
						.prepareStatement("select bjmc from m_class where bjnj="
								+ njlist);
				rs = stmt.executeQuery();
				while (rs.next()) {
					bjmc = rs.getString(1);
					try {
						stmt1 = conn
								.prepareStatement("insert into cg_cglbb(LBID,XXBH,XND,XQ,NJ,KSXZ,BJMC,KSLB,KSMC,KSKSSJ,KSJSSJ,LBXSID) values(?,?,?,?,?,?,?,?,?,?,?,?)");
						int lbid = KeyGenerator.getInstance().getNextKey(
								"cg_cglbb");
						stmt1.setInt(1, lbid);
						stmt1.setInt(2, xxbh);
						stmt1.setString(3, xnd);
						stmt1.setString(4, xq);
						stmt1.setInt(5, njlist);
						stmt1.setString(6, "年级考试");
						stmt1.setString(7, bjmc);
						//stmt1.setInt(8, bjid);
						stmt1.setString(8, kslb);
						stmt1.setString(9, ksmc);
						stmt1.setString(10, kssj);
						stmt1.setString(11, jssj);
						stmt1.setInt(12, lbxsid);
						stmt1.executeUpdate();
					} catch (Exception e) {
						System.out.println(e.getMessage());
						flag = ERROR;
					} finally {
						ProxoolAction.closeStatement(stmt1);
					}
				}
			} catch (Exception e) {
				System.out.println(e.getMessage());
				flag = ERROR;
			} finally {
				ProxoolAction.closeResultSet(rs);
				ProxoolAction.closeStatement(stmt);
				ProxoolAction.closeConnection(conn);
			}
			System.out.println("处理年级考试结束");
		}
		ProxoolAction.closeConnection(conn);
		return flag;
	}
}