empire-db-jakarta-faces/src/main/java/org/apache/empire/jakarta/app/WebApplication.java [475:765]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public UIComponent findComponent(FacesContext fc, String componentId, UIComponent nearComponent) { if (StringUtils.isEmpty(componentId)) throw new InvalidArgumentException("componentId", componentId); // Begin search near given component (if any) UIComponent component = null; if (nearComponent != null) { // Search below the nearest naming container component = nearComponent.findComponent(componentId); if (component == null) { // Recurse upwards UIComponent nextParent = nearComponent; while (true) { nextParent = nextParent.getParent(); // search NamingContainers only while (nextParent != null && !(nextParent instanceof NamingContainer)) { nextParent = nextParent.getParent(); } if (nextParent == null) { break; } else { component = nextParent.findComponent(componentId); } if (component != null) { break; } } } } // Not found. Search the entire tree if (component == null) component = findChildComponent(fc.getViewRoot(), componentId); // done return component; } /** * finds a child component with the given id that is located below the given parent component * @param parent the parent * @param componentId the component id * @return the component or null if no component was found */ public static UIComponent findChildComponent(UIComponent parent, String componentId) { UIComponent component = null; if (parent.getChildCount() == 0) return null; Iterator children = parent.getChildren().iterator(); while (children.hasNext()) { UIComponent nextChild = children.next(); if (nextChild instanceof NamingContainer) { component = nextChild.findComponent(componentId); } if (component == null) { component = findChildComponent(nextChild, componentId); } if (component != null) { break; } } return component; } /** * returns the default input control type for a given data Type * @see org.apache.empire.jakarta.controls.InputControlManager * @param dataType the data type * @return an Input Cnotrol type */ public String getDefaultControlType(DataType dataType) { switch (dataType) { case CLOB: return TextAreaInputControl.NAME; default: return TextInputControl.NAME; } } /* Message handling */ protected void initTextResolvers(Application app) { int count = 0; Iterator locales = app.getSupportedLocales(); for (count = 0; locales.hasNext(); count++) { locales.next(); } // get message bundles String messageBundle = app.getMessageBundle(); textResolvers = new TextResolver[count]; locales = app.getSupportedLocales(); for (int i = 0; locales.hasNext(); i++) { Locale locale = locales.next(); textResolvers[i] = new ResourceTextResolver(ResourceBundle.getBundle(messageBundle, locale)); log.info("added TextResolver for {} bundle='{}'", locale.getLanguage(), messageBundle); } } /** * Obtains a JDBC-Connection from the connection pool * @param db the database for which to obtain a connection * @return the connection */ protected Connection getConnection(DBDatabase db) { // Get From Pool try { // Obtain a connection Connection conn = getAppDataSource(db).getConnection(); conn.setAutoCommit(false); log.trace("Connection {} obtained from pool", conn.hashCode()); return conn; } catch (SQLException e) { log.error("Failed to get connection from pool.", e); throw new InternalException(e); } } /** * Releases a JDBC-Connection from the connection pool * @param conn the connection to release * @param commit flag whether to commit changes * @param dbrm the rollback manager */ protected void releaseConnection(Connection conn, boolean commit, DBRollbackManager dbrm) { try { // check if (conn == null) return; // release connection log.trace("releasing Connection {}", conn.hashCode()); // Commit or rollback connection depending on the exit code if (commit) { // success: commit all changes if (dbrm!=null) dbrm.releaseConnection(conn, ReleaseAction.Discard); // before commit conn.commit(); log.debug("REQUEST commited."); } else { // failure: rollback all changes conn.rollback(); if (dbrm!=null) dbrm.releaseConnection(conn, ReleaseAction.Rollback); // after rollback log.debug("REQUEST rolled back."); } // Release Connection conn.close(); // done if (log.isDebugEnabled()) log.debug("REQUEST returned connection to pool."); } catch (SQLException e) { log.error("Error releasing connection", e); e.printStackTrace(); } } /** * Obtains a DBRollbackManager for the current request * @param fc the FacesContext * @param create if true a DBRollbackManager will be created if not already present * @return the rollback manager */ public DBRollbackManager getRollbackManagerForRequest(FacesContext fc, boolean create) { DBRollbackManager dbrm = (DBRollbackManager)FacesUtils.getRequestAttribute(fc, CONN_ROLLBACK_MANAGER); if (dbrm==null && create) { dbrm = new DBRollbackManager(1, 8); FacesUtils.setRequestAttribute(fc, CONN_ROLLBACK_MANAGER, dbrm); } return dbrm; } /** * Obtains a JDBC-Connection for the current request * @param fc the FacesContext * @param db the DBDatabase for which to obtain a connection * @param create if true a Connection will be created if not already present * @return the connection */ public Connection getConnectionForRequest(FacesContext fc, DBDatabase db, boolean create) { if (fc == null) throw new InvalidArgumentException("FacesContext", fc); if (db == null) throw new InvalidArgumentException("DBDatabase", db); // Get the ConnectionContextInfo map @SuppressWarnings("unchecked") Map connMap = (Map) FacesUtils.getRequestAttribute(fc, REQUEST_CONNECTION_MAP); if (connMap== null && create) { connMap = new HashMap(1); FacesUtils.setRequestAttribute(fc, REQUEST_CONNECTION_MAP, connMap); } else if (connMap==null) { // Nothing to do return null; } Connection conn = connMap.get(db); if (conn==null && create) { // Get Pooled Connection conn = getConnection(db); if (conn== null) throw new UnexpectedReturnValueException(this, "getConnection"); // Add to map connMap.put(db, conn); } // done return conn; } /** * Releases all connections attached to the current request * @param fc the FacesContext * @param commit when true changes are committed otherwise they are rolled back */ public void releaseAllConnections(final FacesContext fc, boolean commit) { @SuppressWarnings("unchecked") Map connMap = (Map) FacesUtils.getRequestAttribute(fc, REQUEST_CONNECTION_MAP); if (connMap == null) return; // Nothing to do // Walk the connection map DBRollbackManager dbrm = getRollbackManagerForRequest(fc, false); for (Connection conn : connMap.values()) { releaseConnection(conn, commit, dbrm); } // remove from request map FacesUtils.setRequestAttribute(fc, REQUEST_CONNECTION_MAP, null); } /** * Releases all connections attached to the current request * If an error is detected in the faces message list, a rollback will automatically be performed insteamd of a commmit * @param fc the FacesContext */ public void releaseAllConnections(final FacesContext fc) { releaseAllConnections(fc, !hasError(fc)); } /** * Releases the connection associated with a database from the request * @param fc the FacesContext * @param db the DBDatabase for which to release the connection * @param commit when true changes are committed otherwise they are rolled back */ public void releaseConnection(final FacesContext fc, DBDatabase db, boolean commit) { @SuppressWarnings("unchecked") Map connMap = (Map) FacesUtils.getRequestAttribute(fc, REQUEST_CONNECTION_MAP); if (connMap == null || !connMap.containsKey(db)) return; // Nothing to do; // Get RollbackManager DBRollbackManager dbrm = getRollbackManagerForRequest(fc, false); // Release Connection Connection conn = connMap.get(db); releaseConnection(conn, commit, dbrm); // Remove from map connMap.remove(db); } /** * Releases the connection associated with a database from the request * If an error is detected in the faces message list, a rollback will automatically be performed insteamd of a commmit * @param fc the FacesContext * @param db the DBDatabase for which to release the connection */ public void releaseConnection(final FacesContext fc, DBDatabase db) { releaseConnection(fc, db, !hasError(fc)); - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - empire-db-jsf2/src/main/java/org/apache/empire/jsf2/app/WebApplication.java [474:764]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public UIComponent findComponent(FacesContext fc, String componentId, UIComponent nearComponent) { if (StringUtils.isEmpty(componentId)) throw new InvalidArgumentException("componentId", componentId); // Begin search near given component (if any) UIComponent component = null; if (nearComponent != null) { // Search below the nearest naming container component = nearComponent.findComponent(componentId); if (component == null) { // Recurse upwards UIComponent nextParent = nearComponent; while (true) { nextParent = nextParent.getParent(); // search NamingContainers only while (nextParent != null && !(nextParent instanceof NamingContainer)) { nextParent = nextParent.getParent(); } if (nextParent == null) { break; } else { component = nextParent.findComponent(componentId); } if (component != null) { break; } } } } // Not found. Search the entire tree if (component == null) component = findChildComponent(fc.getViewRoot(), componentId); // done return component; } /** * finds a child component with the given id that is located below the given parent component * @param parent the parent * @param componentId the component id * @return the component or null if no component was found */ public static UIComponent findChildComponent(UIComponent parent, String componentId) { UIComponent component = null; if (parent.getChildCount() == 0) return null; Iterator children = parent.getChildren().iterator(); while (children.hasNext()) { UIComponent nextChild = children.next(); if (nextChild instanceof NamingContainer) { component = nextChild.findComponent(componentId); } if (component == null) { component = findChildComponent(nextChild, componentId); } if (component != null) { break; } } return component; } /** * returns the default input control type for a given data Type * @see org.apache.empire.jsf2.controls.InputControlManager * @param dataType the data type * @return an Input Cnotrol type */ public String getDefaultControlType(DataType dataType) { switch (dataType) { case CLOB: return TextAreaInputControl.NAME; default: return TextInputControl.NAME; } } /* Message handling */ protected void initTextResolvers(Application app) { int count = 0; Iterator locales = app.getSupportedLocales(); for (count = 0; locales.hasNext(); count++) { locales.next(); } // get message bundles String messageBundle = app.getMessageBundle(); textResolvers = new TextResolver[count]; locales = app.getSupportedLocales(); for (int i = 0; locales.hasNext(); i++) { Locale locale = locales.next(); textResolvers[i] = new ResourceTextResolver(ResourceBundle.getBundle(messageBundle, locale)); log.info("added TextResolver for {} bundle='{}'", locale.getLanguage(), messageBundle); } } /** * Obtains a JDBC-Connection from the connection pool * @param db the database for which to obtain a connection * @return the connection */ protected Connection getConnection(DBDatabase db) { // Get From Pool try { // Obtain a connection Connection conn = getAppDataSource(db).getConnection(); conn.setAutoCommit(false); log.trace("Connection {} obtained from pool", conn.hashCode()); return conn; } catch (SQLException e) { log.error("Failed to get connection from pool.", e); throw new InternalException(e); } } /** * Releases a JDBC-Connection from the connection pool * @param conn the connection to release * @param commit flag whether to commit changes * @param dbrm the rollback manager */ protected void releaseConnection(Connection conn, boolean commit, DBRollbackManager dbrm) { try { // check if (conn == null) return; // release connection log.trace("releasing Connection {}", conn.hashCode()); // Commit or rollback connection depending on the exit code if (commit) { // success: commit all changes if (dbrm!=null) dbrm.releaseConnection(conn, ReleaseAction.Discard); // before commit conn.commit(); log.debug("REQUEST commited."); } else { // failure: rollback all changes conn.rollback(); if (dbrm!=null) dbrm.releaseConnection(conn, ReleaseAction.Rollback); // after rollback log.debug("REQUEST rolled back."); } // Release Connection conn.close(); // done if (log.isDebugEnabled()) log.debug("REQUEST returned connection to pool."); } catch (SQLException e) { log.error("Error releasing connection", e); e.printStackTrace(); } } /** * Obtains a DBRollbackManager for the current request * @param fc the FacesContext * @param create if true a DBRollbackManager will be created if not already present * @return the rollback manager */ public DBRollbackManager getRollbackManagerForRequest(FacesContext fc, boolean create) { DBRollbackManager dbrm = (DBRollbackManager)FacesUtils.getRequestAttribute(fc, CONN_ROLLBACK_MANAGER); if (dbrm==null && create) { dbrm = new DBRollbackManager(1, 8); FacesUtils.setRequestAttribute(fc, CONN_ROLLBACK_MANAGER, dbrm); } return dbrm; } /** * Obtains a JDBC-Connection for the current request * @param fc the FacesContext * @param db the DBDatabase for which to obtain a connection * @param create if true a Connection will be created if not already present * @return the connection */ public Connection getConnectionForRequest(FacesContext fc, DBDatabase db, boolean create) { if (fc == null) throw new InvalidArgumentException("FacesContext", fc); if (db == null) throw new InvalidArgumentException("DBDatabase", db); // Get the ConnectionContextInfo map @SuppressWarnings("unchecked") Map connMap = (Map) FacesUtils.getRequestAttribute(fc, REQUEST_CONNECTION_MAP); if (connMap== null && create) { connMap = new HashMap(1); FacesUtils.setRequestAttribute(fc, REQUEST_CONNECTION_MAP, connMap); } else if (connMap==null) { // Nothing to do return null; } Connection conn = connMap.get(db); if (conn==null && create) { // Get Pooled Connection conn = getConnection(db); if (conn== null) throw new UnexpectedReturnValueException(this, "getConnection"); // Add to map connMap.put(db, conn); } // done return conn; } /** * Releases all connections attached to the current request * @param fc the FacesContext * @param commit when true changes are committed otherwise they are rolled back */ public void releaseAllConnections(final FacesContext fc, boolean commit) { @SuppressWarnings("unchecked") Map connMap = (Map) FacesUtils.getRequestAttribute(fc, REQUEST_CONNECTION_MAP); if (connMap == null) return; // Nothing to do // Walk the connection map DBRollbackManager dbrm = getRollbackManagerForRequest(fc, false); for (Connection conn : connMap.values()) { releaseConnection(conn, commit, dbrm); } // remove from request map FacesUtils.setRequestAttribute(fc, REQUEST_CONNECTION_MAP, null); } /** * Releases all connections attached to the current request * If an error is detected in the faces message list, a rollback will automatically be performed insteamd of a commmit * @param fc the FacesContext */ public void releaseAllConnections(final FacesContext fc) { releaseAllConnections(fc, !hasError(fc)); } /** * Releases the connection associated with a database from the request * @param fc the FacesContext * @param db the DBDatabase for which to release the connection * @param commit when true changes are committed otherwise they are rolled back */ public void releaseConnection(final FacesContext fc, DBDatabase db, boolean commit) { @SuppressWarnings("unchecked") Map connMap = (Map) FacesUtils.getRequestAttribute(fc, REQUEST_CONNECTION_MAP); if (connMap == null || !connMap.containsKey(db)) return; // Nothing to do; // Get RollbackManager DBRollbackManager dbrm = getRollbackManagerForRequest(fc, false); // Release Connection Connection conn = connMap.get(db); releaseConnection(conn, commit, dbrm); // Remove from map connMap.remove(db); } /** * Releases the connection associated with a database from the request * If an error is detected in the faces message list, a rollback will automatically be performed insteamd of a commmit * @param fc the FacesContext * @param db the DBDatabase for which to release the connection */ public void releaseConnection(final FacesContext fc, DBDatabase db) { releaseConnection(fc, db, !hasError(fc)); - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -