dboperation.java

保存图片信息到数据库 数据库Oracle 里面用到的库需要自己重新建立

package src;

import java.sql.*;

public class DBOperation {
	private Connection dbCon = null;

	private Statement state = null;

	private ResultSet rst = null;

	private String dbDriver = "oracle.jdbc.driver.OracleDriver";

	private String dbUrl = "jdbc:oracle:thin:@192.168.2.5:1521:ORGDB005";

	private String userName = "服务定制网站";

	private String passWord = "APPLE";

	/**
	 * 连接数据库
	 * 
	 * @return
	 */
	public boolean connet2DB() {
		if (dbCon == null) {
			try {
				Class.forName(dbDriver);
				dbCon = DriverManager.getConnection(dbUrl, userName, passWord);
				state = dbCon.createStatement();
			} catch (Exception exe) {
				System.out.println("数据库连接失败！\n" + "driver: " + dbDriver
						+ "\nurl: " + dbUrl + "\nuserNam: " + userName
						+ "\npassWord :" + passWord);
				exe.printStackTrace();
				return false;
			}
		}
		return true;
	}

	/**
	 * 
	 * @return
	 */
	public void releaseConnect() {
		if (dbCon != null) {
			try {
				state.close();
				state = null;
				dbCon.close();
				dbCon = null;
			} catch (SQLException sqlExe) {
				System.out.println("释放数据库连接失败！");
				sqlExe.printStackTrace();
			}
		}
	}

	/**
	 * 描述 保存本地图片信息到数据库 参数 serviceID 服务编号 参数 photoName 文件名字 参数 photoContent
	 * 图片内容
	 */
	public synchronized boolean savePhotoInfoToDatabase(String serviceID,
			String photoName, byte[] photoContent) {
		String sqlStr = "insert into TUPIANXXB(FUWUBIANHAO, TUPIANMINGCHENG, TUPIANNEIRONG) values(?, ? , ?)";
		try {
			PreparedStatement preState = dbCon.prepareStatement(sqlStr);
			preState.setString(1, serviceID);
			preState.setString(2, photoName);
			preState.setBytes(3, photoContent);
			preState.execute();
		} catch (SQLException sqlExe) {
			System.out.println("保存图片信息失败!");
			sqlExe.printStackTrace();
		}
		return true;
	}

	/**
	 * 描述：保存信息到数据库 参数：dataName 数据名 参数：serviceID 服务编号 参数：fileContent 文件内容
	 */
	public synchronized void saveInfoToDatabase(String dataName,
			String serviceID, String fileContent) {
		String sqlStr = "insert into BUMENXXB(FUWUBIANHAO, shujuming, WENJIANNEIRONG) values(?, ? , ?)";
		try {
			PreparedStatement preState = dbCon.prepareStatement(sqlStr);
			preState.setString(1, serviceID);
			preState.setString(2, dataName);
			preState.setString(3, fileContent);
			preState.execute();
		} catch (SQLException sqlExe) {
			System.out.println("保存环境信息失败!");
			sqlExe.printStackTrace();
		}
	}

	/**
	 * 读取环境数据信息表 中的文件编号 返回：文件编号
	 * 
	 * @throws SQLException
	 */
	public String getFileID() throws SQLException {

		String sql = "select * from hello";

		// 定义字符串初值非空（若表空则什么都不返回（正确），resultStr的值为HAO）
		// 若定义字符串初值为null，若表为空，则很难判断该语句是否正确
		String resultStr = "HAO";
		try {
			rst = state.executeQuery(sql);
			if (rst.next())// 改变光标位置到第一行前
				resultStr = rst.getString("a");
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return resultStr;
	}

	/**
	 * 获得当前信息的编号
	 * 
	 * @param serviceID
	 *            服务编号
	 * @param typeStr
	 *            类型名（department：部门/workgroup：工作组/role：岗位）
	 * @return
	 */
	public int getID(String serviceID, String typeStr) {
		int maxID = -1;
		String sqlStr = "";
		if (typeStr == "department") {
			sqlStr = " select max(TO_NUMBER(BUMENBIANHAO))"
					+ " from BUMENXXB where FUWUBIANHAO=" + serviceID;
		} else if (typeStr == "workgroup") {
			sqlStr = " select max(TO_NUMBER(GONGZUOZUBIANHAO))"
					+ " from GONGZUOZUXXB where FUWUBIANHAO=" + serviceID;
		} else if (typeStr == "role") {
			sqlStr = " select max(TO_NUMBER(GANGWEIBIANHAO))"
					+ " from GANGWEIXXB where FUWUBIANHAO=" + serviceID;
		} else if (typeStr == "bill") {
			sqlStr = " select max(TO_NUMBER(DANZHENGBIANHAO))"
					+ " from DANZHENGXXB where FUWUBIANHAO=" + serviceID;
		} else if (typeStr == "dbservice") {
			sqlStr = " select max(TO_NUMBER(SHUJUKUFUWUBIANHAO))"
					+ " from SHUJUKUFUWU where FUWUBIANHAO=" + serviceID;
		} else if (typeStr == "flow") {
			sqlStr = " select max(TO_NUMBER(GONGZUOLIUBIANHAO))"
					+ " from LIUCHENGJIBENXXB where FUWUBIANHAO=" + serviceID;
		} else {
			return maxID;
		}
		try {
			rst = state.executeQuery(sqlStr);
			if (rst.next()) {
				maxID = rst.getInt(1) + 1;
			} else {
				maxID = 1;
			}
		} catch (SQLException sqlExe) {
			System.out.println("获得" + typeStr + "编号信息失败！");
			sqlExe.printStackTrace();
		}
		return maxID;
	}

	/**
	 * 保存部门信息到数据库
	 * 
	 * @param serviceID
	 *            服务编号
	 * @param departmentID
	 *            部门编号
	 * @param nameStr
	 *            部门名称
	 * @param rankStr
	 *            部门级别
	 * @param leaderStr
	 *            部门领导
	 * @param viceLeaderStr
	 *            部门副领导
	 * @param assistentStr
	 *            文档管理员
	 * @param commentStr
	 *            注释
	 * @param parentNameStr
	 *            父部门
	 * @param memberStr
	 *            成员列表
	 */
	public synchronized void saveDepartmentInfo(String serviceID,
			String departmentID, String nameStr, String rankStr,
			String leaderStr, String viceLeaderStr, String assistentStr,
			String commentStr, String parentNameStr, String memberStr) {
		String sqlStr = "insert into BUMENXXB(FUWUBIANHAO, BUMENBIANHAO, BUMENMINGCHENG, BUMENJIBIE, "
				+ " BUMENLINGDAO,FULINGDAOMINGCHENG,WENDANGGUANLIYUAN, CHENGYUANLIEBIAO, FUBUMENMINGCHENG, ZHUSHI) values(?, ? , ?, ?, ?, ?, ?, ?, ?, ?)";
		try {
			PreparedStatement preState = dbCon.prepareStatement(sqlStr);
			preState.setString(1, serviceID);
			preState.setString(2, departmentID);
			preState.setString(3, nameStr);
			preState.setString(4, rankStr);
			preState.setString(5, leaderStr);
			preState.setString(6, viceLeaderStr);
			preState.setString(7, assistentStr);
			preState.setString(8, memberStr);
			preState.setString(9, parentNameStr);
			preState.setString(10, commentStr);
			preState.execute();
		} catch (SQLException sqlExe) {
			System.out.println("保存部门信息失败!");
			sqlExe.printStackTrace();
		}
	}

	/**
	 * 保存工作组信息到数据库
	 * 
	 * @param serviceID
	 *            服务编号
	 * @param workGroupID
	 *            工作组编号
	 * @param nameStr
	 *            工作组名称
	 * @param leaderStr
	 *            领导名称
	 * @param commentStr
	 *            注释
	 * @param memberStr
	 *            成员列表
	 */
	public synchronized void saveWorkGroupInfo(String serviceID,
			String workGroupID, String nameStr, String leaderStr,
			String commentStr, String memberStr) {
		String sqlStr = "insert into GONGZUOZUXXB(FUWUBIANHAO, GONGZUOZUBIANHAO, GONGZUOZUMINGCHENG, ZULINGDAO, "
				+ " CHENGYUANLIEBIAO, ZHUSHI) values(?, ? , ?, ?, ?, ?)";
		try {
			PreparedStatement preState = dbCon.prepareStatement(sqlStr);
			preState.setString(1, serviceID);
			preState.setString(2, workGroupID);
			preState.setString(3, nameStr);
			preState.setString(4, leaderStr);
			preState.setString(5, memberStr);
			preState.setString(6, commentStr);
			preState.execute();
		} catch (SQLException sqlExe) {
			System.out.println("保存工作组信息失败!");
			sqlExe.printStackTrace();
		}
	}

	/**
	 * 保存岗位信息到数据库
	 * 
	 * @param serviceID
	 *            服务编号
	 * @param roleID
	 *            岗位编号
	 * @param nameStr
	 *            岗位名称
	 * @param parentNameStr
	 *            父部门名称
	 * @param commentStr
	 *            注释
	 * @param memberStr
	 *            成员列表
	 */
	public synchronized void saveRoleInfo(String serviceID, String roleID,
			String nameStr, String parentNameStr, String commentStr,
			String memberStr) {
		String sqlStr = "insert into GANGWEIXXB(FUWUBIANHAO, GANGWEIBIANHAO, GANGWEIMINGCHENG, GANGWEICHENGYUAN, "
				+ " FUBUMENMINGCHENG, ZHUSHI) values(?, ? , ?, ?, ?, ?)";
		try {
			PreparedStatement preState = dbCon.prepareStatement(sqlStr);
			preState.setString(1, serviceID);
			preState.setString(2, roleID);
			preState.setString(3, nameStr);
			preState.setString(4, memberStr);
			preState.setString(5, parentNameStr);
			preState.setString(6, commentStr);
			preState.execute();
		} catch (SQLException sqlExe) {
			System.out.println("保存角色信息失败!");
			sqlExe.printStackTrace();
		}
	}

	/**
	 * 保存单证信息到数据库
	 * 
	 * @param serviceID
	 *            服务编号
	 * @param billID
	 *            单证编号
	 * @param billName
	 *            单证名称
	 * @param billPath
	 *            单证路径
	 */
	public synchronized void saveBillInfo(String serviceID, String billID,
			String billName, String billPath) {
		String sqlStr = "insert into DANZHENGXXB(FUWUBIANHAO, DANZHENGBIANHAO, "
				+ "DANZHENGMINGCHENG, DANZHENGLUJING) values(?, ? , ?, ?)";
		try {
			PreparedStatement preState = dbCon.prepareStatement(sqlStr);
			preState.setString(1, serviceID);
			preState.setString(2, billID);
			preState.setString(3, billName);
			preState.setString(4, billPath);
			preState.execute();
		} catch (SQLException sqlExe) {
			System.out.println("保存角色信息失败!");
			sqlExe.printStackTrace();
		}
	}

	/**
	 * 保存页面元素信息到数据库
	 * 
	 * @param serviceID
	 *            服务编号
	 * @param billID
	 *            单证编号
	 * @param elemID
	 *            元素编号
	 * @param elemName
	 *            元素名称