| import java.sql.Connection; |
| import java.sql.DriverManager; |
| import java.sql.ResultSet; |
| import java.sql.SQLException; |
| import java.sql.Statement; |
| import java.util.Calendar; |
| import java.util.GregorianCalendar; |
| import java.util.HashMap; |
| import java.util.Map; |
| |
| import lotus.domino.AgentBase; |
| import lotus.domino.AgentContext; |
| import lotus.domino.Database; |
| import lotus.domino.Document; |
| import lotus.domino.Item; |
| import lotus.domino.NotesException; |
| import lotus.domino.Session; |
| import lotus.domino.View; |
| |
| import java.util.Iterator; |
| |
| public class yyystellenPruefung extends AgentBase { |
| |
| private long lastMillis = System.currentTimeMillis(); |
| |
| private Database dbCurrent = null; |
| |
| |
| |
| |
| |
| private Document logDoc; |
| private Item logItem; |
| |
| |
| |
| private String strOracleView; |
| private long newDocs = 0; |
| private long logCount; |
| private long logDocCount; |
| |
| |
| |
| private Connection connectToOracle(Document docOracleConfig) throws SQLException, NotesException { |
| logEvent("vor Driver " + System.currentTimeMillis()); |
| DriverManager.registerDriver(new oracle.jdbc.driver.OracleDriver()); |
| logEvent("vor conn " + System.currentTimeMillis()); |
| String strOracleServer = docOracleConfig |
| .getItemValueString("OracleServer"); |
| String strOracleUser = docOracleConfig.getItemValueString("OracleUser"); |
| String strOraclePwd = docOracleConfig.getItemValueString("OraclePwd"); |
| |
| |
| Connection conn = DriverManager.getConnection("jdbc:oracle:thin:@" |
| + strOracleServer, strOracleUser, strOraclePwd); |
| |
| |
| |
| if (conn.isClosed()) { |
| logEvent("Oracle Connection is not open yet."); |
| return null; |
| } |
| |
| return conn; |
| |
| } |
| |
| public void NotesMain() { |
| Connection conn = null; |
| try { |
| System.out |
| .println("Agent: Check für yyystellenaenderungen neu gestartet"); |
| Session session = getSession(); |
| AgentContext agentContext = session.getAgentContext(); |
| dbCurrent = agentContext.getCurrentDatabase(); |
| |
| |
| |
| Calendar cal = new GregorianCalendar(); |
| logDoc = dbCurrent.createDocument(); |
| logDoc.replaceItemValue("Form", "Log"); |
| logDoc.replaceItemValue("Lauf", "Lauf vom: " |
| + cal.get(Calendar.DATE) + "." |
| + (cal.get(Calendar.MONTH) + 1) + "." |
| + cal.get(Calendar.YEAR) + " " |
| + cal.get(Calendar.HOUR_OF_DAY) + ":" |
| + cal.get(Calendar.MINUTE) + " Uhr"); |
| logDoc.replaceItemValue("Start", cal.get(Calendar.DATE) + "." |
| + (cal.get(Calendar.MONTH) + 1) + "." |
| + cal.get(Calendar.YEAR) + " " |
| + cal.get(Calendar.HOUR_OF_DAY) + ":" |
| + cal.get(Calendar.MINUTE) + " Uhr"); |
| |
| logDoc.replaceItemValue("Log", ""); |
| logItem = logDoc.getFirstItem("Log"); |
| logEvent("neuer Agent: Check für yyystellenüberprüfung gestartet"); |
| logDoc.save(true, false); |
| |
| |
| |
| View oracleConfigView = dbCurrent.getView("(luConfig)"); |
| Document docOracleConfig = oracleConfigView.getDocumentByKey("OracleConfig"); |
| |
| strOracleView = docOracleConfig.getItemValueString("OracleView"); |
| |
| |
| |
| |
| |
| |
| |
| |
| conn = connectToOracle(docOracleConfig); |
| |
| if (conn != null) { |
| logEvent("Datenbankanbindung an ACAT erfolgreich hergestellt"); |
| |
| |
| |
| View terminalView = dbCurrent.getView("(luACATAbfrage)"); |
| Document terminalDoc = terminalView.getFirstDocument(); |
| |
| |
| |
| |
| Map mapTerminalDoc = new HashMap(); |
| while (terminalDoc != null) { |
| Document nextDoc = terminalView |
| .getNextDocument(terminalDoc); |
| VOTerminalDoc termDoc = new VOTerminalDoc(); |
| termDoc.setBkuName(terminalDoc |
| .getItemValueString("BKUName")); |
| termDoc.setNotesUniversalId(terminalDoc.getUniversalID()); |
| |
| termDoc.setXxxstelle(terminalDoc |
| .getItemValueString("xxxstelle")); |
| termDoc.setYyystelle(terminalDoc |
| .getItemValueString("yyystelle")); |
| |
| mapTerminalDoc.put(termDoc.getBkuName(), termDoc); |
| |
| terminalDoc.recycle(); |
| terminalDoc = nextDoc; |
| |
| } |
| |
| checkyyyInfo(mapTerminalDoc, conn); |
| |
| logDoc.save(true, false); |
| logDoc.recycle(); |
| |
| |
| |
| |
| |
| |
| } |
| |
| } catch (Exception e) { |
| |
| e.printStackTrace(); |
| |
| } finally { |
| try { |
| if (conn != null) { |
| conn.close(); |
| } |
| |
| } catch (SQLException e) { |
| |
| } |
| |
| } |
| } |
| |
| public void checkyyyInfo(Map mapTerminalDoc, Connection conn) { |
| |
| try { |
| logEvent("vor Abfrage " + System.currentTimeMillis()); |
| |
| String query = "Select BKUName, name_von_spalte_3, name_von_spalte_4 From " |
| + strOracleView |
| + " WHERE BKUName IN " |
| + buildSelectInQueryCondition(mapTerminalDoc.keySet() |
| .iterator()); |
| System.out.println("QUERY=" + query); |
| Statement stmt = conn.createStatement(); |
| ResultSet rs = stmt.executeQuery(query); |
| logEvent(query + "-->" + System.currentTimeMillis()); |
| if (rs.next()) { |
| String bkuName = rs.getString("BKUName"); |
| VOTerminalDoc termDoc = (VOTerminalDoc) mapTerminalDoc |
| .get(bkuName); |
| |
| String strxxxstelleFromDb = new String(rs |
| .getString("name_von_spalte_3")); |
| String stryyystelleFromDb = new String(rs |
| .getString("name_von_spalte_4")); |
| |
| if (strxxxstelleFromDb != termDoc.getXxxstelle() |
| || strxxxstelleFromDb != termDoc.getYyystelle()) { |
| Document updateDoc = dbCurrent.getDocumentByUNID(termDoc |
| .getNotesUniversalId()); |
| System.out.println("updating doc ->" + termDoc); |
| fillyyyInfo(updateDoc, strxxxstelleFromDb, |
| stryyystelleFromDb); |
| } |
| |
| } |
| |
| |
| rs.close(); |
| |
| } |
| |
| catch (Exception e) { |
| e.printStackTrace(); |
| } |
| } |
| |
| private String buildSelectInQueryCondition(Iterator itKeys) { |
| StringBuffer buf = new StringBuffer(); |
| buf.append("("); |
| while (itKeys.hasNext()) { |
| String key = itKeys.next().toString(); |
| buf.append("'"); |
| buf.append(key); |
| buf.append("'"); |
| } |
| buf.append(")"); |
| |
| return buf.toString(); |
| |
| } |
| |
| private void fillyyyInfo(Document updateDoc, String stryyystelle, |
| String strxxxstelle) { |
| try { |
| |
| String common = updateDoc.getItemValueString("zzzName"); |
| |
| updateDoc.replaceItemValue("xxxstelle", stryyystelle); |
| updateDoc.replaceItemValue("yyystelle", strxxxstelle); |
| logEvent(common + System.currentTimeMillis()); |
| |
| updateDoc.save(true, false); |
| updateDoc.recycle(); |
| |
| } |
| |
| catch (Exception e) { |
| e.printStackTrace(); |
| } |
| } |
| |
| private void logEvent(String eventToBeLogged) { |
| try { |
| Calendar cal = new GregorianCalendar(); |
| logCount++; |
| logItem.appendToTextList(eventToBeLogged); |
| if (logCount > 200) { |
| logDocCount++; |
| logCount = 0; |
| logDoc.save(true, false); |
| logDoc = dbCurrent.createDocument(); |
| logDoc.replaceItemValue("Form", "Log"); |
| logDoc.replaceItemValue("Lauf", "Lauf vom: " |
| + cal.get(Calendar.DATE) + "." |
| + (cal.get(Calendar.MONTH) + 1) + "." |
| + cal.get(Calendar.YEAR) + " " |
| + cal.get(Calendar.HOUR_OF_DAY) + ":" |
| + cal.get(Calendar.MINUTE) + " Uhr " + logDocCount |
| + ". Teil"); |
| logDoc.replaceItemValue("Log", ""); |
| logItem = logDoc.getFirstItem("Log"); |
| } |
| } catch (Exception e) { |
| e.printStackTrace(); |
| } |
| } |
| |
| public long getDifMillis() { |
| long newMillis = System.currentTimeMillis(); |
| long dif = newMillis - lastMillis; |
| lastMillis = newMillis; |
| return dif; |
| } |
| |
| } |
| |
| class VOTerminalDoc { |
| private String bkuName; |
| private String notesUniversalId; |
| private String xxxstelle; |
| private String yyystelle; |
| |
| public String getBkuName() { |
| return bkuName; |
| } |
| |
| public void setBkuName(String bkuName) { |
| this.bkuName = bkuName; |
| } |
| |
| public String getNotesUniversalId() { |
| return notesUniversalId; |
| } |
| |
| public void setNotesUniversalId(String notesUniversalId) { |
| this.notesUniversalId = notesUniversalId; |
| } |
| |
| public String getXxxstelle() { |
| return xxxstelle; |
| } |
| |
| public void setXxxstelle(String xxxstelle) { |
| this.xxxstelle = xxxstelle; |
| } |
| |
| public String getYyystelle() { |
| return yyystelle; |
| } |
| |
| public void setYyystelle(String yyystelle) { |
| this.yyystelle = yyystelle; |
| } |
| |
| public String toString() { |
| return "[" + getClass().getName() + "\n\tbkuName=" + getBkuName() |
| + "\n\tnotesUniversalId=" + getNotesUniversalId() |
| + "\n\txxxstelle=" + getXxxstelle() + "\n\tyyystelle=" |
| + getYyystelle() + "\n]"; |
| } |
| |
| } |
Thema: Abfrage auf Oracle-DB dauert sehr labge (Gelesen 11816 mal)