sjzddao.java

数据字典 TAG标签 用于支持数据对照 支持各种radio check list显示

package com.beiktech.hib.dao;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;

import org.hibernate.HibernateException;
import org.hibernate.Session;
import org.hibernate.Transaction;

import com.beiktech.hib.po.SjzdPo;

public class SjzdDao {
	private Session session;

	private Statement st;

	private PreparedStatement ps;

	private String sql;

	private ResultSet rs;

	private String impClassname = "com.beiktech.hib.dao.SjzdImp";

	public SjzdDao() {
		if (PropertyManager.getProperty("impClassname") != null)
			impClassname = PropertyManager.getProperty("impClassname");
		Class clazz = null;
		try {
			clazz = ReflectHelper.classForName(impClassname); // 初始化处理商业类
		} catch (ClassNotFoundException ex) {

		}
		try {
			imp = (SjzdInterface) clazz.newInstance();
		} catch (IllegalAccessException ex1) {
			ex1.printStackTrace();

		} catch (InstantiationException ex1) {
			ex1.printStackTrace();
		}
	}

	private SjzdInterface imp;

	// 查询所有的根级数据
	public List findAllRoot() {
		sql = "select * from " + imp.getSjzdTableName()
				+ " where sjzd_fcode='ROOT' order by sjzd_pos";
		List list = null;
		try {
			st = this.getCn().createStatement();
			rs = st.executeQuery(sql);
			list = new ArrayList();
			while (rs.next()) {
				SjzdPo sp = new SjzdPo();
				sp.setCode(rs.getString("sjzd_code"));
				sp.setFcode(rs.getString("sjzd_fcode"));
				sp.setFfcode(rs.getString("sjzd_ffcode"));
				sp.setName(rs.getString("sjzd_name"));
				sp.setPos(rs.getInt("sjzd_pos"));
				sp.setValid(rs.getString("sjzd_zt"));
				sp.setType(rs.getString("sjzd_beiy"));
				sp.setEdit(rs.getString("sjzd_edit"));
				sp.setExplain(rs.getString("sjzd_explain"));
				list.add(sp);
			}
		} catch (HibernateException e) {
			e.printStackTrace();
		} catch (SQLException e) {
			e.printStackTrace();
		} 
		return list;
	}

	// 查询所有的下级数据
	public List findAllOption(String code, String fcode) {
		sql = "select * from " + imp.getSjzdTableName() + " where sjzd_fcode='"
				+ code + "'and sjzd_ffcode='" + fcode + "' order by sjzd_pos";
		List list = null;
		try {
			st = this.getCn().createStatement();
			rs = st.executeQuery(sql);
			list = new ArrayList();
			while (rs.next()) {
				SjzdPo sp = new SjzdPo();
				sp.setCode(rs.getString("sjzd_code"));
				sp.setFcode(rs.getString("sjzd_fcode"));
				sp.setFfcode(rs.getString("sjzd_ffcode"));
				sp.setName(rs.getString("sjzd_name"));
				sp.setPos(rs.getInt("sjzd_pos"));
				sp.setValid(rs.getString("sjzd_zt"));
				sp.setType(rs.getString("sjzd_beiy"));
				sp.setEdit(rs.getString("sjzd_edit"));
				sp.setExplain(rs.getString("sjzd_explain"));
				list.add(sp);
			}
		} catch (HibernateException e) {
			e.printStackTrace();
		} catch (SQLException e) {
			e.printStackTrace();
		} 
		return list;
	}

	// 判断是否有下级
	public boolean ifChildren(String code, String fcode) {
		sql = "select * from " + imp.getSjzdTableName() + " where sjzd_fcode='"
				+ code + "' and sjzd_ffcode='" + fcode + "'";
		try {
			st = this.getCn().createStatement();
			rs = st.executeQuery(sql);
			if (rs.next()) {
				return true;
			}
		} catch (HibernateException e) {
			e.printStackTrace();
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return false;
	}

	// 查询单个根级数据
	public SjzdPo findRoot(String code) {
		sql = "select * from " + imp.getSjzdTableName() + " where sjzd_code='"
				+ code + "' and sjzd_fcode='ROOT'";
		try {
			st = this.getCn().createStatement();
			rs = st.executeQuery(sql);
			rs.next();
			SjzdPo sp = new SjzdPo();
			sp.setCode(rs.getString("sjzd_code"));
			sp.setFcode(rs.getString("sjzd_fcode"));
			sp.setFfcode(rs.getString("sjzd_ffcode"));
			sp.setName(rs.getString("sjzd_name"));
			sp.setPos(rs.getInt("sjzd_pos"));
			sp.setValid(rs.getString("sjzd_zt"));
			sp.setType(rs.getString("sjzd_beiy"));
			sp.setEdit(rs.getString("sjzd_edit"));
			sp.setExplain(rs.getString("sjzd_explain"));
			return sp;
		} catch (HibernateException e) {
			e.printStackTrace();
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return null;
	}

	// 查询单个下级数据
	public SjzdPo findOption(String code, String fcode) {
		sql = "select * from " + imp.getSjzdTableName() + " where sjzd_code='"
				+ code + "' and sjzd_fcode='" + fcode + "'";
		try {
			st = this.getCn().createStatement();
			rs = st.executeQuery(sql);
			rs.next();
			SjzdPo sp = new SjzdPo();
			sp.setCode(rs.getString("sjzd_code"));
			sp.setFcode(rs.getString("sjzd_fcode"));
			sp.setFfcode(rs.getString("sjzd_ffcode"));
			sp.setName(rs.getString("sjzd_name"));
			sp.setPos(rs.getInt("sjzd_pos"));
			sp.setValid(rs.getString("sjzd_zt"));
			sp.setType(rs.getString("sjzd_beiy"));
			sp.setEdit(rs.getString("sjzd_edit"));
			sp.setExplain(rs.getString("sjzd_explain"));
			return sp;
		} catch (HibernateException e) {
			e.printStackTrace();
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return null;
	}

	// 添加数据
	public boolean add(SjzdPo sp) {
		sql = "insert into "
			+ imp.getSjzdTableName()
			+ "(sjzd_code,sjzd_fcode,sjzd_name,sjzd_ffcode,sjzd_pos,sjzd_zt,sjzd_beiy,sjzd_edit,sjzd_explain)" 
			+ " value(?,?,?,?,?,?,?,?,?)";

		try {
			Connection con = this.getCn();
			con.setAutoCommit(true);
			PreparedStatement ps = con.prepareStatement(sql);
			ps.setString(1, sp.getCode().toUpperCase());
			ps.setString(3, sp.getName());
			ps.setString(2, sp.getFcode().toUpperCase());
			ps.setString(4, sp.getFfcode().toUpperCase());
			ps.setInt(5, sp.getPos());
			ps.setString(6, sp.getValid());
			ps.setString(7, sp.getType());
			ps.setString(8, sp.getEdit());
			ps.setString(9, sp.getExplain());
			ps.execute();

		} catch (HibernateException e) {
			e.printStackTrace();
			return false;
		} catch (SQLException e) {
			e.printStackTrace();
			return false;
		}
		return true;
	}

	// 添加根级数据
	public boolean addRoot(SjzdPo sp) {
		return this.add(sp);
	}

	// 添加下级数据
	public boolean addOption(SjzdPo sp) {
		return this.add(sp);
	}

	// 更新数据
	public boolean update(SjzdPo sp) {
		String code = sp.getCode();
		String fcode = sp.getFcode();
		sql = "update " + imp.getSjzdTableName()
				+ " set sjzd_name=?,sjzd_pos=?,sjzd_zt=? ,sjzd_beiy=? , sjzd_explain=? where sjzd_code='"
				+ code + "' and sjzd_fcode='" + fcode + "'";

		try {
			Connection con = this.getCn();
			con.setAutoCommit(true);
			PreparedStatement ps = con.prepareStatement(sql);
			ps.setString(1, sp.getName());
			ps.setInt(2, sp.getPos());
			ps.setString(3, sp.getValid());
			ps.setString(4, sp.getType());
			ps.setString(5, sp.getExplain());
			ps.execute();

		} catch (HibernateException e) {
			e.printStackTrace();
			return false;
		} catch (SQLException e) {
			e.printStackTrace();
			return false;
		}
		return true;
	}

	// 更新根级数据
	public boolean updateRoot(SjzdPo sp) {
		return this.update(sp);
	}

	// 更新下级数据
	public boolean updateOption(SjzdPo sp) {
		return this.update(sp);
	}
	
	//判断能否添加子级
	public boolean ifAddOption(SjzdPo sp) {
		if(sp.getType().equalsIgnoreCase("0")){
			return true;
		}
		return false;
	}
	
	//
	public boolean ifEdit(SjzdPo sp){
		if(sp.getEdit().equalsIgnoreCase("0")){
			return true;
		}
		return false;
	}
	// 删除数据
	public boolean delete(String code, String fcode) {
		sql = "delete from " + imp.getSjzdTableName() + " where sjzd_code='"
				+ code + "' and sjzd_fcode='" + fcode + "'";
		String sqlOption = "delete from " + imp.getSjzdTableName()
				+ " where sjzd_fcode='" + code + "' and sjzd_ffcode='" + fcode
				+ "'";

		try {
			Connection con = this.getCn();
			con.setAutoCommit(true);
			st = con.createStatement();
			st.executeUpdate(sql);
			st.executeUpdate(sqlOption);
		} catch (HibernateException e) {
			e.printStackTrace();
			return false;
		} catch (SQLException e) {
			e.printStackTrace();
			return false;
		} finally {
		}
		return true;
	}

	// 删除根级数据
	public boolean deleteRoot(String code, String fcode) {
		return this.delete(code, fcode);
	}

	// 删除下级数据
	public boolean deleteOption(String code, String fcode) {
		return this.delete(code, fcode);
	}

	//得到数据连接
	public Connection getCn() {
		return imp.getConnection();
	}
	//得到session

}