inputdatadboperatorproperty.java

一个数据挖掘软件ALPHAMINERR的整个过程的JAVA版源代码

				m_MessageDialog.showWarning(
						Resource.srcStr("AllInformationMessage"),
						"Warning");
				return false;
			}

			if (seLDB_Driver == DB2_Driver)
				dbDriverName = DB2_ParameterValue;
			else if (seLDB_Driver == MYSQL_Driver)
				dbDriverName = MYSQL_ParameterValue;
			else if (seLDB_Driver == ORACLE_Driver)
				dbDriverName = ORACLE_ParameterValue;
			else if (seLDB_Driver == MSSQL_Driver)
				dbDriverName = MSSQL_ParameterValue;
			else if (seLDB_Driver == POSTGRE_Driver)
				dbDriverName = POSTGRE_ParameterValue;
			dbDriver = "sun.jdbc.odbc.JdbcOdbcDriver";
		}

		String url;
		if (seLDB_Driver == JDBC_ODBC_Driver) {
			url = "jdbc:odbc:" + dbName;
		} else {
			url = "jdbc:odbc:" + dbName;
		}

		//    	System.out.println( url + "\n");
		//    	System.out.println( dbUser + "\n");
		//    	System.out.println( dbPassword + "\n");
		//    	System.out.println(dbDriver + "\n");
		try {
			MiningSqlSource a_Source = new MiningSqlSource(url, dbUser,
					dbPassword, dbDriver);
			a_Source.getConnection();

			String ls_sql = "";
			if (m_RadioSQL.isSelected()) {
				ls_sql = query.trim();

			} else {
				// MySQL is not allowed to have special characters and double
				// quote "" in the tablename
				// Access is allowed to have soecial characters in table name, a
				// double quote is needed in this case
				if (ValueValidator.containSpecialChar(dbTableName)) {
					ls_sql = "select  * from " + "\"" + dbTableName + "\"";
				} else {
					ls_sql = "select  * from " + dbTableName;
				}

			}

			MiningSqlStream a_Input = new MiningSqlStream(a_Source, ls_sql);
			InputDataDBOperator op = (InputDataDBOperator) m_Operator;
			
			op.clearResult();
			BIData aBIData = new BIData(m_CaseID, m_NodeID);
			aBIData.setMetaData(a_Input.getMetaData());
			aBIData.setDataSourceName(dbName + "_" + m_Node.getNodeID());
			op.getOutputBIObject().setBIData(aBIData);
			m_Node.setName(dbName);
			op.setDataDBOperatorText("Input Database ["
					+ aBIData.getDataSourceName() + "]");
			op.setDefaultDataSourceName(aBIData.getDataSourceName());
			m_Node.setParameterValue("defaultDataSourceName", aBIData
					.getDataSourceName());
			a_Input.close();
		} catch (MiningException me) {
			//			JOptionPane.showMessageDialog(m_ParentPanel.getCaseWindow(),
			//						  "Error in loading meta data: " + me.getMessage(),
			//						  "Error", JOptionPane.ERROR_MESSAGE);
			m_MessageDialog.showError("Error in loading meta data: "
					+ me.getMessage(), "Error");
			return false;

		}
		//		 set m_Node param if no error
		m_Node.setParameterValue(SOURCE_TYPE_ParameterValue, dbDriverName);

		m_Node.setParameterValue(DSN_ParameterValue, dbName);
		m_Node.setParameterValue(HOST_ParameterValue, host);
		m_Node.setParameterValue(PORT_ParameterValue, port);

		m_Node.setParameterValue(DBName_ParameterValue, dbName);
		m_Node.setParameterValue(DBUser_ParameterValue, dbUser);
		m_Node.setParameterValue(pwd_ParameterValue, dbPassword);
		m_Node.setParameterValue(dbDriver_ParameterValue, dbDriver);

		m_Node.setParameterValue(table_ParameterValue, dbTableName);
		m_Node.setParameterValue(url_ParameterValue, url);
		m_Node.setParameterValue(query_ParameterValue, query);
		//<< ADDED BY JOYCE 2005/03/02
		if (m_RadioTable.isSelected()) {
			m_Node.setParameterValue(option_ParameterValue, "TABLE");
		} else if (m_RadioSQL.isSelected()) {
			m_Node.setParameterValue(option_ParameterValue, "SQL");
		}
		//>>
		//m_ParentPanel.getCaseWindow().setModified(true);
		setPropertiesModified();
		//OPTION
		this.setTitle("Input Database [" + m_Node.getName() + "_"
				+ m_Node.getNodeID() + "]");
		return true;
	}

	public void getContent() {
/*		BICase selectedCase = null;
		try {
			selectedCase = CaseHandler.getInstance().getCase(m_CaseID, false);
		} catch (BaseException be) {
			System.out.println(be.getMessage());
			m_selectedDBComboBox.setEnabled(false);
			return;
		}

		if (selectedCase == null) {
			System.out.println("selected case null");
			m_selectedDBComboBox.setEnabled(false);
			return;
		}*/
		//OperatorNode m_Node = (OperatorNode) selectedCase.getNode(
			//	NodeFactory.OPERATOR, m_NodeID);
		/*curNm_Node= node;
		if (node == null) {
			System.out.println("node null " + m_NodeID);
			m_selectedDBComboBox.setEnabled(false);
			return;
		}*/

		String sourceType = (String) m_Node.getParameterValue(SOURCE_TYPE_ParameterValue);
		if (sourceType == null) {
			setEnableDBPanel(false);
			m_selectedDBComboBox.setEnabled(false);
			return;

		} else if (sourceType.equals(ODBC_ParameterValue)
				|| (sourceType.equals(DB2_ParameterValue))
				|| (sourceType.equals(MYSQL_ParameterValue))
				|| (sourceType.equals(ORACLE_ParameterValue))
				|| (sourceType.equals(MSSQL_ParameterValue))
				|| (sourceType.equals(POSTGRE_ParameterValue))) {

			String dbengine, host, port, dsn, dbName, dbUrl, dbUser, dbPwd, dbDriver, dbTable, dbQuery;

			/*
			 * String name = m_Node.getParameterValue(DBName_ParameterValue );
			 * String user = m_Node.getParameterValue(DBUser_ParameterValue);
			 * String password = m_Node.getParameterValue(pwd_ParameterValue );
			 * String driver = m_Node.getParameterValue(dbDriver_ParameterValue );
			 * String table = m_Node.getParameterValue(table_ParameterValue);
			 * String SQLquery = m_Node.getParameterValue(query_ParameterValue );
			 */

			dbengine = ODBC_ParameterValue; // will change later
			host = (String) m_Node.getParameterValue(HOST_ParameterValue);
			port = (String) m_Node.getParameterValue(PORT_ParameterValue);
			dsn = (String) m_Node.getParameterValue(DSN_ParameterValue);
			dbName = (String) m_Node.getParameterValue(DBName_ParameterValue);
			dbUrl = (String) m_Node.getParameterValue(url_ParameterValue);
			dbUser = (String) m_Node.getParameterValue(DBUser_ParameterValue);
			dbPwd = (String) m_Node.getParameterValue(pwd_ParameterValue);
			dbDriver = (String) m_Node.getParameterValue(dbDriver_ParameterValue);
			dbTable = (String) m_Node.getParameterValue(table_ParameterValue);
			dbQuery = (String) m_Node.getParameterValue(query_ParameterValue);

			//<<
			String option = (String) m_Node.getParameterValue(option_ParameterValue);
			//>>

			//setDBSource(name, user, password, driver, table, SQLquery);
			setDBSource(dbengine, host, port, dsn, dbName, dbUrl, dbUser,
					dbPwd, dbDriver, dbTable, dbQuery, option);
			setDefaultDataSourceName((String) m_Node
					.getParameterValue("defaultDataSourceName"));
		} else {
			return;
		}
	}

	private void ResetDBPanel() {
		m_RadioTable.setSelected(true);
		m_RadioTable.setEnabled(false);
		m_RadioSQL.setSelected(false);
		m_selectedDBComboBox.removeAllItems();
		m_selectedDBComboBox.addItem("Please select...");
		m_SelectedTableComboBox.removeAllItems();
		m_SelectedTableComboBox.addItem("Please select...");
		editorPane.setText("");
	}

	private void setEnableDBPanel(boolean flag) {
		//m_selectedDBComboBox.setEnabled(flag);
		m_RadioTable.setEnabled(flag);
		m_RadioSQL.setEnabled(flag);
		m_SelectedTableComboBox.setEnabled(flag);
		editorPane.setEnabled(flag);
	}

	private void setEnabledTable(boolean flag) {
		m_SelectedTableComboBox.setEnabled(flag);
		//        if (!flag)
		//            m_SelectedTableComboBox.setSelectedIndex(0);
	}

	private void setEnabledSQL(boolean flag) {
		editorPane.setEnabled(flag);
		//        if (!flag)
		//            editorPane.setText("");
	}

	public void setDBSource(String dbengine, String host, String port,
			String dsn, String dbname, String dbUrl, String user,
			String password, String driver, String table, String SQLquery,
			String option) {
		//setDBSource(dbengine, host, port, dsn, dbName, dbUrl, dbUser, dbPwd,
		// dbDriver, dbTable, dbQuery);

		if (dbengine == null)
			dbengine = "";
		if (host == null)
			host = "";
		if (port == null)
			port = "";
		if (dsn == null)
			dsn = "";
		if (dbname == null)
			dbname = "";
		if (dbUrl == null)
			dbUrl = "";
		if (user == null)
			user = "";
		if (password == null)
			password = "";
		if (driver == null)
			driver = "";
		if (table == null)
			table = "";
		if (SQLquery == null)
			SQLquery = "";

		// Database Server
/*		BICase selectedCase = null;
		try {
			selectedCase = CaseHandler.getInstance().getCase(m_CaseID, false);
		} catch (BaseException be) {
			System.out.println(be.getMessage());
			return;
		}*/
		//OperatorNodm_Nodede = (OperatorNode) selectedCase.getNode(
			//	NodeFactory.OPERATOR, m_NodeID);
		String sourceType = (String) m_Node.getParameterValue(SOURCE_TYPE_ParameterValue);
		// ODBC options
		if (sourceType.equals(ODBC_ParameterValue)) {
			m_DBDriver.setSelectedIndex(JDBC_ODBC_Driver);
			String DSN = (String) m_Node.getParameterValue(DSN_ParameterValue);

			for (int i = 0; i < m_DSNComboBox.getItemCount(); i++) {
				if (m_DSNComboBox.getItemAt(i).toString().equals(DSN)) {
					m_DSNComboBox.setSelectedIndex(i);
					break;
				}
			}

			// Add later
		} else {
			// other db
			if (sourceType.equals(ODBC_ParameterValue))
				m_DBDriver.setSelectedIndex(JDBC_ODBC_Driver);
			if (sourceType.equals(DB2_ParameterValue))
				m_DBDriver.setSelectedIndex(DB2_Driver);
			if (sourceType.equals(MYSQL_ParameterValue))
				m_DBDriver.setSelectedIndex(MYSQL_Driver);
			if (sourceType.equals(ORACLE_ParameterValue))
				m_DBDriver.setSelectedIndex(ORACLE_Driver);
			if (sourceType.equals(MSSQL_ParameterValue))
				m_DBDriver.setSelectedIndex(MSSQL_Driver);
			if (sourceType.equals(POSTGRE_ParameterValue))
				m_DBDriver.setSelectedIndex(POSTGRE_Driver);

			//String host = m_Node.getParameterValue(HOST_ParameterValue);
			//String port = m_Node.getParameterValue(PORT_ParameterValue);

			m_host.setText(host);
			m_Port.setText(port);
		}
		// set other information
		m_DBUser.setText(user);
		m_DBPassword.setText(password);
		//System.out.println("TABLE = " + option);
		if (option.toUpperCase().equals("TABLE")) {
			this.m_RadioSQL.setSelected(false);
			this.m_RadioTable.setSelected(true);
		} else {
			this.m_RadioSQL.setSelected(true);
			this.m_RadioTable.setSelected(false);
		}

		connectToSever();
		// set Database

		for (int i = 0; i < m_SelectedTableComboBox.getItemCount(); i++) {
			if (m_SelectedTableComboBox.getItemAt(i).toString().equals(table)) {
				m_SelectedTableComboBox.setSelectedIndex(i);
				break;
			}
		}

		if (SQLquery.length() <= 0) {
			editorPane.setText("");

		} else {
			editorPane.setText(SQLquery);
		}

	}

	private void setDefaultDataSourceName(String a_SourceName) {
		InputDataDBOperator op = (InputDataDBOperator) m_Operator;
		op.setDefaultDataSourceName(a_SourceName);
	}
	
	public void resetLocale() {
		
		//title
		String title = getTitle();
		int index = title.indexOf('[');
		title = Resource.srcStr("InputDatabaseTitle1")+title.substring(index);
		setTitle(title);
		
		m_connectButton.setText(Resource.srcStr("m_connectButton"));
		m_hostLabel.setText(Resource.srcStr("m_hostLabel"));
		m_portLabel.setText(Resource.srcStr("m_portLabel"));
		m_DSNLabel.setText(Resource.srcStr("m_DSNLabel"));
		m_RadioTable.setText(Resource.srcStr("m_RadioTable"));
		m_RadioSQL.setText(Resource.srcStr("m_RadioSQL"));
		driverStrings[0] = Resource.srcStr("SelectItem");
		
		((TitledBorder)((CompoundBorder)m_dbPanel.getBorder()).getOutsideBorder()).setTitle(Resource.srcStr("database"));
		
		m_border1.setTitle(Resource.srcStr("m_border1"));
		driverLabel.setText(Resource.srcStr("driver"));
		UsernameLabel.setText(Resource.srcStr("m_LabelUsername"));
		PasswordLabel.setText(Resource.srcStr("m_LabelPassword"));
		database.setText(Resource.srcStr("database"));
		source.setText(Resource.srcStr("source"));
				
		m_ButtonApply.setText(Resource.srcStr("m_ButtonApply"));
		m_ButtonReset.setText(Resource.srcStr("m_ButtonReset"));
		m_ButtonClose.setPreferredSize(m_defaultButtonSize);
	}
}