mssqlkjavadao.java

一个免费wap站

    			item.setIndexId(rst.getInt("IndexID"));
    			item.setKjavaId(rst.getInt("ParentID"));
    			item.setDeviceManufacturer(rst.getInt("DeviceManufacturer"));
    			item.setJadFile(rst.getString("JADFile"));
    			item.setFileSize(rst.getInt("FileSize"));
    			item.setAccessCount(rst.getInt("AccessCount"));
    			item.setDescription(rst.getString("Description"));
    			item.setDeviceModels(rst.getString("DeviceModels"));
        	}

		} catch (Exception e) {
			e.printStackTrace();
			AppLogger.debug("MSSqlKJavaDAO.getKJavaStorage().e.getMessage()=" + e.getMessage());

			throw new ResourceDAOSysException(e.getMessage());
		} finally {
			try {
				super.closeStatement(stmt);
				super.closeConnection(conn);
			} catch (Exception e) {
				throw new ResourceDAOSysException(e.getMessage());
			}
		}

		return item;
	}

	public void updateKJava(KJava item) throws ResourceDAOSysException {
		Connection conn = null;
		PreparedStatement stmt = null;

		String sql = "UPDATE TAB_KJAVA SET SortOrder = ?, LastUpdate = ?, IsActive = ?, IsSearchable = ?," 
			+ "SearchKeywords = ?, PropertyNames = ?, PropertyValues = ? "
			+ "WHERE IndexID = ?";

		AppLogger.debug("MSSqlKJavaDAO.updateKJava().sql=" + sql);

		try {
			conn = super.getDBConnection();
			stmt = conn.prepareStatement(sql);
			fillKJavaParameters(stmt, item, TYPE_UPDATE);

		    int rowCount = stmt.executeUpdate();
		    
		    if (rowCount != 1)
		    	throw new ResourceDAOSysException("effected row count must be 1");


		} catch (Exception e) {
			AppLogger.debug("MSSqlKJavaDAO.updateKJava().e.getMessage()=" + e.getMessage());

			throw new ResourceDAOSysException(e.getMessage());

		} finally {
			try {
				super.closeStatement(stmt);
				super.closeConnection(conn);
			} catch (Exception e) {
				throw new ResourceDAOSysException(e.getMessage());
			}
		}
	}
	
	

	public void deleteKJava(int indexId) throws ResourceDAOSysException {
		Connection conn = null;
		PreparedStatement stmt = null;

		String sql = "UPDATE TAB_KJAVA SET Deleted = 1 WHERE IndexID = ?";

		AppLogger.debug("MSSqlKJavaDAO.deleteKJava().sql=" + sql);

		try {
			conn = super.getDBConnection();
			stmt = conn.prepareStatement(sql);
			stmt.setInt(1, indexId);

		    int rowCount = stmt.executeUpdate();
		    
		    if (rowCount != 1)
		    	throw new ResourceDAOSysException("effected row count must be 1");
		} catch (Exception e) {
			AppLogger.debug("MSSqlKJavaDAO.deleteKJava().e.getMessage()=" + e.getMessage());

			throw new ResourceDAOSysException(e.getMessage());

		} finally {
			try {
				super.closeStatement(stmt);
				super.closeConnection(conn);
			} catch (Exception e) {
				throw new ResourceDAOSysException(e.getMessage());
			}
		}
	}

	public KJava getKJava(int indexId) throws ResourceDAOSysException {
		Connection conn = null;
		PreparedStatement stmt = null;
		ResultSet rst = null;
		
		KJava item = null;
		String sql = "SELECT IndexID, ParentID, SortOrder, DateCreated, LastUpdate, IsActive, IsSearchable, SearchKeywords, PropertyNames, PropertyValues FROM TAB_KJAVA WHERE IndexID = ?";
		AppLogger.debug("MSSqlKJavaDAO.getKJava().sql=" + sql);
		try {
			conn = super.getDBConnection();
			stmt = conn.prepareStatement(sql);
			stmt.setInt(1, indexId);

			rst = stmt.executeQuery();

        	if (rst.next()) {
    			item = populateKJavaFormResultSet(rst);
        	}
		} catch (Exception e) {
			AppLogger.debug("MSSqlKJavaDAO.getKJava().e.getMessage()=" + e.getMessage());

			throw new ResourceDAOSysException(e.getMessage());
		} finally {
			try {
				super.closeResultSet(rst);
				super.closeStatement(stmt);
				super.closeConnection(conn);
			} catch (Exception e) {
				throw new ResourceDAOSysException(e.getMessage());
			}
		}
		return item;
	}

	public void createKJavaStorage(KJavaStorage item) throws ResourceDAOSysException {
		Connection conn = null;
		PreparedStatement stmt = null;

		String sql = "INSERT INTO TAB_KJAVASTORAGE (ParentID, DeviceModels, DeviceManufacturer, JADFile, FileSize, AccessCount, Description) " 
			+ "VALUES (?,?,?,?,?,?,?)";

		AppLogger.debug("MSSqlPictureDAO.createKJavaStorage().sql=" + sql);

		try {
			conn = super.getDBConnection();
			stmt = conn.prepareStatement(sql);
			fillKJavaStorageParameters(stmt, item, TYPE_ADD);

		    int rowCount = stmt.executeUpdate();
		    
		    if (rowCount != 1)
		    	throw new ResourceDAOSysException("effected row count must be 1");


		} catch (Exception e) {
			AppLogger.debug("MSSqlKJavaDAO.createKJavaStorage().e.getMessage()=" + e.getMessage());

			throw new ResourceDAOSysException(e.getMessage());

		} finally {
			try {
				super.closeStatement(stmt);
				super.closeConnection(conn);
			} catch (Exception e) {
				throw new ResourceDAOSysException(e.getMessage());
			}
		}
	}

	public void updateKJavaStorage(KJavaStorage item) throws ResourceDAOSysException {
		Connection conn = null;
		PreparedStatement stmt = null;

		String sql = "UPDATE TAB_KJAVASTORAGE SET DeviceModels = ?, DeviceManufacturer = ?, JADFile = ?, FileSize = ?, AccessCount = ?, Description = ? " 
			+ "WHERE IndexID = ?";

		AppLogger.debug("MSSqlPictureDAO.updateKJavaStorage().sql=" + sql);

		try {
			conn = super.getDBConnection();
			stmt = conn.prepareStatement(sql);
			fillKJavaStorageParameters(stmt, item, TYPE_UPDATE);

		    int rowCount = stmt.executeUpdate();
		    
		    if (rowCount != 1)
		    	throw new ResourceDAOSysException("effected row count must be 1");


		} catch (Exception e) {
			AppLogger.debug("MSSqlKJavaDAO.updateKJavaStorage().e.getMessage()=" + e.getMessage());

			throw new ResourceDAOSysException(e.getMessage());

		} finally {
			try {
				super.closeStatement(stmt);
				super.closeConnection(conn);
			} catch (Exception e) {
				throw new ResourceDAOSysException(e.getMessage());
			}
		}
	}

	public void deleteKJavaStorage(int indexId) throws ResourceDAOSysException {
		Connection conn = null;
		PreparedStatement stmt = null;

		String sql = "UPDATE TAB_KJAVASTORAGE SET Deleted = 1 WHERE IndexID = ?";

		AppLogger.debug("MSSqlPictureDAO.deleteKJavaStorage().sql=" + sql);

		try {
			conn = super.getDBConnection();
			stmt = conn.prepareStatement(sql);
			stmt.setInt(1, indexId);

		    int rowCount = stmt.executeUpdate();
		    
		    if (rowCount != 1)
		    	throw new ResourceDAOSysException("effected row count must be 1");


		} catch (Exception e) {
			AppLogger.debug("MSSqlKJavaDAO.deleteKJavaStorage().e.getMessage()=" + e.getMessage());

			throw new ResourceDAOSysException(e.getMessage());

		} finally {
			try {
				super.closeStatement(stmt);
				super.closeConnection(conn);
			} catch (Exception e) {
				throw new ResourceDAOSysException(e.getMessage());
			}
		}
	}

	protected void fillKJavaStorageParameters(PreparedStatement stmt, KJavaStorage item, int type) throws SQLException {
		int index = 1;
		try {
			if (type == TYPE_ADD) {
				stmt.setInt(index++, item.getKjavaId());
				stmt.setString(index++, item.dumpDeviceModels());
				stmt.setInt(index++, item.getDeviceManufacturer());
				stmt.setString(index++, item.getJadFile());
				stmt.setInt(index++, item.getFileSize());
				stmt.setInt(index++, item.getAccessCount());
				stmt.setString(index++, item.getDescription());
			} else if (type == TYPE_UPDATE) {
				stmt.setString(index++, item.dumpDeviceModels());
				stmt.setInt(index++, item.getDeviceManufacturer());
				stmt.setString(index++, item.getJadFile());
				stmt.setInt(index++, item.getFileSize());
				stmt.setInt(index++, item.getAccessCount());
				stmt.setString(index++, item.getDescription());
				stmt.setInt(index++, item.getIndexId());
			}
		} catch (SQLException e) {
			throw e;
		}
	}
}