February 2011 - Wikitty-commits - mailman.cloud.codelutin.com

r729 - trunk/wikitty-solr-impl/src/main/java/org/nuiton/wikitty/storage/solr
by bpoussin＠users.nuiton.org 23 Feb '11

23 Feb '11

Author: bpoussin Date: 2011-02-23 16:51:35 +0100 (Wed, 23 Feb 2011) New Revision: 729 Url: http://nuiton.org/repositories/revision/wikitty/729 Log: change some log level from debug to trace, and abbreviate fieldvalue Modified: trunk/wikitty-solr-impl/src/main/java/org/nuiton/wikitty/storage/solr/WikittySearchEngineSolr.java Modified: trunk/wikitty-solr-impl/src/main/java/org/nuiton/wikitty/storage/solr/WikittySearchEngineSolr.java =================================================================== --- trunk/wikitty-solr-impl/src/main/java/org/nuiton/wikitty/storage/solr/WikittySearchEngineSolr.java 2011-02-23 15:40:54 UTC (rev 728) +++ trunk/wikitty-solr-impl/src/main/java/org/nuiton/wikitty/storage/solr/WikittySearchEngineSolr.java 2011-02-23 15:51:35 UTC (rev 729) @@ -61,7 +61,9 @@ import java.io.File; import java.util.Collections; +import org.apache.commons.lang.StringUtils; import org.nuiton.util.ApplicationConfig; +import org.nuiton.util.StringUtil; import org.nuiton.util.TimeLog; import org.nuiton.wikitty.WikittyConfig; import org.nuiton.wikitty.WikittyUtil; @@ -877,9 +879,10 @@ doc.addField(solrFqFieldName, fieldValue); doc.addField(solrAllFieldName, fieldValue); solrNullFieldFqFieldNameValue = "false"; - if (log.isDebugEnabled()) { - log.debug("index field " + solrFqFieldName - + " with value '" + fieldValue + "'"); + if (log.isTraceEnabled()) { + log.trace(String.format("index field '%s' with value '%s'", + solrFqFieldName, + StringUtils.abbreviate(String.valueOf(fieldValue), 50))); } } doc.addField(solrNullFieldFqFieldName, solrNullFieldFqFieldNameValue); @@ -927,8 +930,8 @@ * @return solrInputDocument used to modify index */ protected SolrInputDocument createIndexDocument(Wikitty w) { - if (log.isDebugEnabled()) { - log.debug("index wikitty " + w.getId()); + if (log.isTraceEnabled()) { + log.trace(String.format("create index wikitty for '%s'", w.getId())); } SolrInputDocument doc = new SolrInputDocument();

1 0

r728 - trunk/wikitty-solr-impl/src/main/java/org/nuiton/wikitty/storage/solr
by bpoussin＠users.nuiton.org 23 Feb '11

23 Feb '11

Author: bpoussin Date: 2011-02-23 16:40:54 +0100 (Wed, 23 Feb 2011) New Revision: 728 Url: http://nuiton.org/repositories/revision/wikitty/728 Log: change store indexation for attachment if not present in Storage or in Transaction. Create partial document for futur storage of this document Modified: trunk/wikitty-solr-impl/src/main/java/org/nuiton/wikitty/storage/solr/WikittySearchEngineSolr.java Modified: trunk/wikitty-solr-impl/src/main/java/org/nuiton/wikitty/storage/solr/WikittySearchEngineSolr.java =================================================================== --- trunk/wikitty-solr-impl/src/main/java/org/nuiton/wikitty/storage/solr/WikittySearchEngineSolr.java 2011-02-23 15:40:00 UTC (rev 727) +++ trunk/wikitty-solr-impl/src/main/java/org/nuiton/wikitty/storage/solr/WikittySearchEngineSolr.java 2011-02-23 15:40:54 UTC (rev 728) @@ -164,9 +164,6 @@ Map<String, Wikitty> allWikitties = new HashMap<String, Wikitty>(); // les ids des wikitties en parametre reellement modifier (a reindexer) Set<String> dirtyObject = new HashSet<String>(); - // les ids des wikitties qui n'appartiennent pas a un TreeNode passé en - // parametre, mais qui pourrait appartenir a un treenode deja indexe - Set<String> possibleAttachment = new HashSet<String>(); // les ids des TreeNodes dont le champs parent a change (est aussi // contenu dans dirtyObject Set<String> dirtyParent = new HashSet<String>(); @@ -220,13 +217,14 @@ Wikitty w = allWikitties.get(id); SolrDocument oldDoc = dirtyObjectDoc.get(id); SolrInputDocument doc = createIndexDocument(w); - if (oldDoc == null) { - // Le document n'existait pas, mais peut-etre qu'il etait - // dans la liste des attachments d'un TreeNode. Il faudra - // donc rechercher si c'est le cas et l'indexer convenablement - possibleAttachment.add(id); - } else { - // copy des champs #tree.attached + if (oldDoc != null) { + // On a un ancien document partiel ou complet + // s'il etait partiel (seulement l'indexation arbre + // cela veut dire que l'objet TreeNode a ete store + // sans que l'attachment le soit et qu'il l'est que + // maintenant + + // copy des champs #tree.attached des documents partiels ou non SolrUtil.copySolrDocument(oldDoc, doc, TREENODE_ATTACHED + ".*"); if (WikittyTreeNodeHelper.hasExtension(w) && !dirtyParentDoc.containsKey(id)) { @@ -326,15 +324,7 @@ // Phase 3: on reindexe les attachments qui en ont besoin // - // on ajoute les attachment au TreeNode qui ont ete store, sans - // leurs attachments (ni en base, ni dans le meme store) - Map<String, SolrDocument> tree = - SolrUtil.findAllByAttachment(solrServer, possibleAttachment); - for (SolrDocument doc : tree.values()) { - attachmentInTree.add(doc, possibleAttachment); - } - - addTreeIndexField(solrResource, tree, attachmentInTree); + addTreeIndexField(solrResource, null, attachmentInTree); } catch (Exception eee) { throw new WikittyException("Can't store wikitty", eee); } @@ -605,20 +595,23 @@ // reindexation totale). Ceci n'est pas un probleme car // les attachments seront convenablement indexes lorsqu'ils // seront ajoutes - if (oldDoc != null || doc != null) { - if (doc == null) { - doc = new SolrInputDocument(); - SolrUtil.copySolrDocument(oldDoc, doc); - solrResource.addDoc(attId, doc); - } - doc.removeField(TREENODE_ATTACHED + treeNodeId); - for (Object id : treeNodeParents) { - doc.addField(TREENODE_ATTACHED + treeNodeId, id); - } - } else { - // FIXME, il faut tout de meme creer le document - // avec seulement l'id et l'indexation arbre + if (oldDoc == null && doc == null) { + // L'objet en attachment du TreeNode, n'est pas encore + // store et n'est pas dans le meme appel de la methode + // store. On cree donc un document Partiel (seulement + // constitue de l'id et de l'indexation d'arbre qui sera + // reutilise lors du store de reel objet + doc = new SolrInputDocument(); + addToIndexDocument(doc, null, SOLR_ID, attId); + } else if (doc == null) { + doc = new SolrInputDocument(); + SolrUtil.copySolrDocument(oldDoc, doc); + solrResource.addDoc(attId, doc); } + doc.removeField(TREENODE_ATTACHED + treeNodeId); + for (Object id : treeNodeParents) { + doc.addField(TREENODE_ATTACHED + treeNodeId, id); + } } } }

1 0

r727 - trunk/wikitty-jdbc-impl/src/main/java/org/nuiton/wikitty/jdbc
by bpoussin＠users.nuiton.org 23 Feb '11

23 Feb '11

Author: bpoussin Date: 2011-02-23 16:40:00 +0100 (Wed, 23 Feb 2011) New Revision: 727 Url: http://nuiton.org/repositories/revision/wikitty/727 Log: remove double ;; Modified: trunk/wikitty-jdbc-impl/src/main/java/org/nuiton/wikitty/jdbc/WikittyStorageJDBC.java Modified: trunk/wikitty-jdbc-impl/src/main/java/org/nuiton/wikitty/jdbc/WikittyStorageJDBC.java =================================================================== --- trunk/wikitty-jdbc-impl/src/main/java/org/nuiton/wikitty/jdbc/WikittyStorageJDBC.java 2011-02-23 15:18:43 UTC (rev 726) +++ trunk/wikitty-jdbc-impl/src/main/java/org/nuiton/wikitty/jdbc/WikittyStorageJDBC.java 2011-02-23 15:40:00 UTC (rev 727) @@ -626,7 +626,7 @@ @Override public DataStatistic getDataStatistic(WikittyTransaction transaction) { - DataStatistic result;; + DataStatistic result; Connection connection = WikittyJDBCUtil.getConnection(config); try { Statement statement = connection.createStatement();

1 0

r726 - trunk/wikitty-solr-impl/src/main/java/org/nuiton/wikitty/storage/solr
by bpoussin＠users.nuiton.org 23 Feb '11

23 Feb '11

Author: bpoussin Date: 2011-02-23 16:18:43 +0100 (Wed, 23 Feb 2011) New Revision: 726 Url: http://nuiton.org/repositories/revision/wikitty/726 Log: add TimeLog for store and delete method Modified: trunk/wikitty-solr-impl/src/main/java/org/nuiton/wikitty/storage/solr/WikittySearchEngineSolr.java Modified: trunk/wikitty-solr-impl/src/main/java/org/nuiton/wikitty/storage/solr/WikittySearchEngineSolr.java =================================================================== --- trunk/wikitty-solr-impl/src/main/java/org/nuiton/wikitty/storage/solr/WikittySearchEngineSolr.java 2011-02-23 15:03:43 UTC (rev 725) +++ trunk/wikitty-solr-impl/src/main/java/org/nuiton/wikitty/storage/solr/WikittySearchEngineSolr.java 2011-02-23 15:18:43 UTC (rev 726) @@ -62,6 +62,7 @@ import java.io.File; import java.util.Collections; import org.nuiton.util.ApplicationConfig; +import org.nuiton.util.TimeLog; import org.nuiton.wikitty.WikittyConfig; import org.nuiton.wikitty.WikittyUtil; import org.nuiton.wikitty.entities.WikittyTreeNodeHelper; @@ -79,7 +80,8 @@ public class WikittySearchEngineSolr implements WikittySearchEngine { /** to use log facility, just put in your code: log.info(\"...\"); */ - static private Log log = LogFactory.getLog(WikittySearchEngineSolr.class); + final static private Log log = LogFactory.getLog(WikittySearchEngineSolr.class); + final static private TimeLog timeLog = new TimeLog(WikittySearchEngineSolr.class); /** solr server */ protected SolrServer solrServer; @@ -154,6 +156,7 @@ @Override public void store(WikittyTransaction transaction, Collection<Wikitty> wikitties, boolean force) { + long startTime = TimeLog.getTime(); try { solrResource.init(); @@ -335,6 +338,8 @@ } catch (Exception eee) { throw new WikittyException("Can't store wikitty", eee); } + timeLog.log(startTime, "store", String.format( + "nb %s in force mode %s", wikitties.size(), force)); } /** @@ -357,6 +362,7 @@ */ @Override public void delete(WikittyTransaction transaction, Collection<String> ids) throws WikittyException { + long startTime = TimeLog.getTime(); try { solrResource.init(); @@ -470,6 +476,9 @@ } catch (Exception eee) { throw new WikittyException("Can't delete wikitty in index", eee); } + timeLog.log(startTime, "delete", String.format( + "nb %s", ids.size())); + } /** @@ -606,6 +615,9 @@ for (Object id : treeNodeParents) { doc.addField(TREENODE_ATTACHED + treeNodeId, id); } + } else { + // FIXME, il faut tout de meme creer le document + // avec seulement l'id et l'indexation arbre } } }

1 0

r725 - trunk/wikitty-api/src/main/java/org/nuiton/wikitty/services
by bpoussin＠users.nuiton.org 23 Feb '11

23 Feb '11

Author: bpoussin Date: 2011-02-23 16:03:43 +0100 (Wed, 23 Feb 2011) New Revision: 725 Url: http://nuiton.org/repositories/revision/wikitty/725 Log: commit transaction avec statistic request Modified: trunk/wikitty-api/src/main/java/org/nuiton/wikitty/services/WikittyServiceStorage.java Modified: trunk/wikitty-api/src/main/java/org/nuiton/wikitty/services/WikittyServiceStorage.java =================================================================== --- trunk/wikitty-api/src/main/java/org/nuiton/wikitty/services/WikittyServiceStorage.java 2011-02-23 14:58:46 UTC (rev 724) +++ trunk/wikitty-api/src/main/java/org/nuiton/wikitty/services/WikittyServiceStorage.java 2011-02-23 15:03:43 UTC (rev 725) @@ -949,6 +949,14 @@ WikittyStorage.DataStatistic stat = getWikittyStorage().getDataStatistic(tx); final long max = stat.getActiveWikitties(); + if (txBeginHere) { + tx.commit(); + } + if (!tx.isStarted()) { + tx.begin(); + txBeginHere = true; + } + log.info("Reindexation 0%"); getWikittyStorage().scanWikitties(tx, new WikittyStorage.Scanner() { long lastPurcent = -1;

1 0

r724 - trunk/wikitty-jdbc-impl/src/main/java/org/nuiton/wikitty/jdbc
by echatellier＠users.nuiton.org 23 Feb '11

23 Feb '11

Author: echatellier Date: 2011-02-23 15:58:46 +0100 (Wed, 23 Feb 2011) New Revision: 724 Url: http://nuiton.org/repositories/revision/wikitty/724 Log: Fix catch Modified: trunk/wikitty-jdbc-impl/src/main/java/org/nuiton/wikitty/jdbc/WikittyJDBCUtil.java Modified: trunk/wikitty-jdbc-impl/src/main/java/org/nuiton/wikitty/jdbc/WikittyJDBCUtil.java =================================================================== --- trunk/wikitty-jdbc-impl/src/main/java/org/nuiton/wikitty/jdbc/WikittyJDBCUtil.java 2011-02-23 14:42:12 UTC (rev 723) +++ trunk/wikitty-jdbc-impl/src/main/java/org/nuiton/wikitty/jdbc/WikittyJDBCUtil.java 2011-02-23 14:58:46 UTC (rev 724) @@ -318,10 +318,12 @@ public static void closeQuietly(Connection connection) { try { if (connection != null) { + // delegate close can throw NPE + // so this is necessary to catch all Exceptions connection.close(); } - } catch (SQLException e) { - log.error("SQLException while closing connection", e); + } catch (Exception e) { + log.error("Exception while closing connection", e); } }

1 0

r723 - trunk/wikitty-jdbc-impl/src/main/java/org/nuiton/wikitty/jdbc
by bpoussin＠users.nuiton.org 23 Feb '11

23 Feb '11

Author: bpoussin Date: 2011-02-23 15:42:12 +0100 (Wed, 23 Feb 2011) New Revision: 723 Url: http://nuiton.org/repositories/revision/wikitty/723 Log: close only if connection is not null Modified: trunk/wikitty-jdbc-impl/src/main/java/org/nuiton/wikitty/jdbc/WikittyJDBCUtil.java Modified: trunk/wikitty-jdbc-impl/src/main/java/org/nuiton/wikitty/jdbc/WikittyJDBCUtil.java =================================================================== --- trunk/wikitty-jdbc-impl/src/main/java/org/nuiton/wikitty/jdbc/WikittyJDBCUtil.java 2011-02-23 12:26:47 UTC (rev 722) +++ trunk/wikitty-jdbc-impl/src/main/java/org/nuiton/wikitty/jdbc/WikittyJDBCUtil.java 2011-02-23 14:42:12 UTC (rev 723) @@ -317,7 +317,9 @@ */ public static void closeQuietly(Connection connection) { try { - connection.close(); + if (connection != null) { + connection.close(); + } } catch (SQLException e) { log.error("SQLException while closing connection", e); }

1 0

r722 - in trunk/wikitty-solr-impl/src: main/java/org/nuiton/wikitty/storage/solr test/java/org/nuiton/wikitty/storage/solr
by bpoussin＠users.nuiton.org 23 Feb '11

23 Feb '11

Author: bpoussin Date: 2011-02-23 13:26:47 +0100 (Wed, 23 Feb 2011) New Revision: 722 Url: http://nuiton.org/repositories/revision/wikitty/722 Log: trace time of all solr query (if log level ask it) Modified: trunk/wikitty-solr-impl/src/main/java/org/nuiton/wikitty/storage/solr/AttachmentInTree.java trunk/wikitty-solr-impl/src/main/java/org/nuiton/wikitty/storage/solr/Restriction2Solr.java trunk/wikitty-solr-impl/src/main/java/org/nuiton/wikitty/storage/solr/SolrUtil.java trunk/wikitty-solr-impl/src/main/java/org/nuiton/wikitty/storage/solr/WikittySearchEngineSolr.java trunk/wikitty-solr-impl/src/test/java/org/nuiton/wikitty/storage/solr/SolrServerTest.java Modified: trunk/wikitty-solr-impl/src/main/java/org/nuiton/wikitty/storage/solr/AttachmentInTree.java =================================================================== --- trunk/wikitty-solr-impl/src/main/java/org/nuiton/wikitty/storage/solr/AttachmentInTree.java 2011-02-23 12:15:14 UTC (rev 721) +++ trunk/wikitty-solr-impl/src/main/java/org/nuiton/wikitty/storage/solr/AttachmentInTree.java 2011-02-23 12:26:47 UTC (rev 722) @@ -162,6 +162,7 @@ * * @param id TreeNode id * @param attId attachment id + * @since 3.0.5 */ public void add(String id, String attId) { if (attId != null) { @@ -189,6 +190,7 @@ * * @param doc TreeNode document representation * @param restriction la liste accepte de wikitty a ajouter + * @since 3.0.5 */ public void add(SolrDocument doc, Set<String> restriction) { String id = (String)doc.getFieldValue(WikittySolrConstant.SOLR_ID); Modified: trunk/wikitty-solr-impl/src/main/java/org/nuiton/wikitty/storage/solr/Restriction2Solr.java =================================================================== --- trunk/wikitty-solr-impl/src/main/java/org/nuiton/wikitty/storage/solr/Restriction2Solr.java 2011-02-23 12:15:14 UTC (rev 721) +++ trunk/wikitty-solr-impl/src/main/java/org/nuiton/wikitty/storage/solr/Restriction2Solr.java 2011-02-23 12:26:47 UTC (rev 722) @@ -204,7 +204,7 @@ query.setRows(MAX_SUBQUERY_RESULT); QueryResponse resp = null; try { - resp = solr.query(query); + resp = SolrUtil.executeQuery(solr, query); } catch (SolrServerException e) { throw new WikittyException("Unable to execute associative query on " + associated.getElement().getName(), e); } Modified: trunk/wikitty-solr-impl/src/main/java/org/nuiton/wikitty/storage/solr/SolrUtil.java =================================================================== --- trunk/wikitty-solr-impl/src/main/java/org/nuiton/wikitty/storage/solr/SolrUtil.java 2011-02-23 12:15:14 UTC (rev 721) +++ trunk/wikitty-solr-impl/src/main/java/org/nuiton/wikitty/storage/solr/SolrUtil.java 2011-02-23 12:26:47 UTC (rev 722) @@ -41,6 +41,7 @@ import java.util.HashSet; import java.util.Map; import java.util.Set; +import org.nuiton.util.TimeLog; import org.nuiton.wikitty.entities.WikittyTreeNode; import static org.nuiton.wikitty.storage.solr.WikittySolrConstant.SOLR_ID; @@ -64,7 +65,8 @@ public class SolrUtil { /** to use log facility, just put in your code: log.info(\"...\"); */ - static private Log log = LogFactory.getLog(SolrUtil.class); + final static private Log log = LogFactory.getLog(SolrUtil.class); + final static private TimeLog timeLog = new TimeLog(SolrUtil.class); /** * Recherche tous les TreeNode auquel appartient en Attachment l'objet passe @@ -167,7 +169,7 @@ request += ")"; SolrQuery query = new SolrQuery(request); - QueryResponse response = solrServer.query(query); + QueryResponse response = executeQuery(solrServer, query); SolrDocumentList results = response.getResults(); for (SolrDocument doc : results) { String id = (String) doc.getFieldValue(SOLR_ID); @@ -181,6 +183,27 @@ } /** + * Execute SolrQuery on specified SolrServer and return the result + * + * @param solrServer + * @param query + * @return + * @throws SolrServerException + */ + static public QueryResponse executeQuery(SolrServer solrServer, SolrQuery query) + throws SolrServerException { + long start = TimeLog.getTime(); + QueryResponse result = solrServer.query(query); + + long numGet = result.getResults().size(); + long numfound = result.getResults().getNumFound(); + timeLog.log(start, "executeQuery", String.format( + "nb result %s/%s query was '%s'", numGet, numfound, query)); + + return result; + } + + /** * if you change this method, change * {@link TypeFieldModifer#convertToField(org.nuiton.wikitty.services.WikittyTransaction, java.lang.String)} * too Modified: trunk/wikitty-solr-impl/src/main/java/org/nuiton/wikitty/storage/solr/WikittySearchEngineSolr.java =================================================================== --- trunk/wikitty-solr-impl/src/main/java/org/nuiton/wikitty/storage/solr/WikittySearchEngineSolr.java 2011-02-23 12:15:14 UTC (rev 721) +++ trunk/wikitty-solr-impl/src/main/java/org/nuiton/wikitty/storage/solr/WikittySearchEngineSolr.java 2011-02-23 12:26:47 UTC (rev 722) @@ -688,7 +688,7 @@ if(log.isDebugEnabled()) { log.debug(String.format("Try to execute query %s", query)); } - QueryResponse resp = solrServer.query(query); + QueryResponse resp = SolrUtil.executeQuery(solrServer, query); SolrDocumentList solrResults = resp.getResults(); Map<String, List<FacetTopic>> facets = new HashMap<String, List<FacetTopic>>(); @@ -778,7 +778,7 @@ String queryString = restriction2Solr.toSolr( treeCriteria.getRestriction(), solrServer); SolrQuery query = new SolrQuery(SOLR_QUERY_PARSER + queryString); - QueryResponse resp = solrServer.query(query); + QueryResponse resp = SolrUtil.executeQuery(solrServer, query); SolrDocumentList solrResults = resp.getResults(); Map<String, Integer> counts = new HashMap<String, Integer>(); Modified: trunk/wikitty-solr-impl/src/test/java/org/nuiton/wikitty/storage/solr/SolrServerTest.java =================================================================== --- trunk/wikitty-solr-impl/src/test/java/org/nuiton/wikitty/storage/solr/SolrServerTest.java 2011-02-23 12:15:14 UTC (rev 721) +++ trunk/wikitty-solr-impl/src/test/java/org/nuiton/wikitty/storage/solr/SolrServerTest.java 2011-02-23 12:26:47 UTC (rev 722) @@ -30,21 +30,15 @@ import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; -import org.apache.solr.client.solrj.SolrQuery; import org.apache.solr.client.solrj.SolrServer; import org.apache.solr.client.solrj.SolrServerException; import org.apache.solr.client.solrj.embedded.EmbeddedSolrServer; -import org.apache.solr.client.solrj.response.QueryResponse; import org.apache.solr.common.SolrDocument; -import org.apache.solr.common.SolrDocumentList; import org.apache.solr.common.SolrInputDocument; import org.apache.solr.core.CoreContainer; import org.junit.Before; import org.junit.Ignore; import org.junit.Test; -import org.nuiton.wikitty.storage.solr.SolrUtil; -import org.nuiton.wikitty.storage.solr.WikittySearchEngineSolr; -import org.nuiton.wikitty.storage.solr.WikittySolrConstant; /** * Test behaviour SolrServer embedded.

1 0

r721 - in trunk: . wikitty-api/src/main/java/org/nuiton/wikitty
by bpoussin＠users.nuiton.org 23 Feb '11

23 Feb '11

Author: bpoussin Date: 2011-02-23 13:15:14 +0100 (Wed, 23 Feb 2011) New Revision: 721 Url: http://nuiton.org/repositories/revision/wikitty/721 Log: use new TimeLog class to replace TimeTrace Modified: trunk/pom.xml trunk/wikitty-api/src/main/java/org/nuiton/wikitty/WikittyProxy.java Modified: trunk/pom.xml =================================================================== --- trunk/pom.xml 2011-02-23 10:01:28 UTC (rev 720) +++ trunk/pom.xml 2011-02-23 12:15:14 UTC (rev 721) @@ -508,7 +508,7 @@  <eugeneVersion>2.3.1</eugeneVersion> - <nuitonUtilsVersion>2.0</nuitonUtilsVersion> + <nuitonUtilsVersion>2.1-SNAPSHOT</nuitonUtilsVersion> <nuitonI18nVersion>2.2</nuitonI18nVersion> <processPluginVersion>1.1</processPluginVersion> Modified: trunk/wikitty-api/src/main/java/org/nuiton/wikitty/WikittyProxy.java =================================================================== --- trunk/wikitty-api/src/main/java/org/nuiton/wikitty/WikittyProxy.java 2011-02-23 10:01:28 UTC (rev 720) +++ trunk/wikitty-api/src/main/java/org/nuiton/wikitty/WikittyProxy.java 2011-02-23 12:15:14 UTC (rev 721) @@ -29,7 +29,7 @@ import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.nuiton.util.ApplicationConfig; -import org.nuiton.util.TimeTrace; +import org.nuiton.util.TimeLog; import org.nuiton.wikitty.entities.BusinessEntity; import org.nuiton.wikitty.entities.BusinessEntityImpl; import org.nuiton.wikitty.entities.Wikitty; @@ -69,10 +69,9 @@ public class WikittyProxy { /** to use log facility, just put in your code: log.info(\"...\"); */ - static private Log log = LogFactory.getLog(WikittyProxy.class); + final static private Log log = LogFactory.getLog(WikittyProxy.class); + final static private TimeLog timeLog = new TimeLog(WikittyProxy.class); - static protected TimeTrace timeTrace = new TimeTrace(); - /** Delegated wikitty service. */ protected WikittyServiceEnhanced wikittyService; @@ -95,8 +94,8 @@ WIKITTY_PROXY_TIME_TO_LOG_INFO.getKey()); long timeToLogWarn = config.getOptionAsInt(WikittyConfig.WikittyOption. WIKITTY_PROXY_TIME_TO_LOG_WARN.getKey()); - timeTrace.setTimeToLogInfo(timeToLogInfo); - timeTrace.setTimeToLogWarn(timeToLogWarn); + timeLog.setTimeToLogInfo(timeToLogInfo); + timeLog.setTimeToLogWarn(timeToLogWarn); } } @@ -115,27 +114,27 @@ setWikittyService(wikittyService); } - static public TimeTrace getTimeTrace() { - return timeTrace; + static public TimeLog getTimeTrace() { + return timeLog; } - static public Map<String, TimeTrace.CallStat> getCallCount() { - return timeTrace.getCallCount(); + static public Map<String, TimeLog.CallStat> getCallCount() { + return timeLog.getCallCount(); } public void login(String login, String password) { - long start = TimeTrace.getTime(); + long start = TimeLog.getTime(); String result = wikittyService.login(login, password); setSecurityToken(result); - timeTrace.add(start, "login"); + timeLog.log(start, "login"); } public void logout() { - long start = TimeTrace.getTime(); + long start = TimeLog.getTime(); wikittyService.logout(securityToken); - timeTrace.add(start, "logout"); + timeLog.log(start, "logout"); } public String getSecurityToken() { @@ -163,11 +162,11 @@ * @return new instance of object wanted */ public <E extends BusinessEntity> E cast(BusinessEntity source, Class<E> target) { - long start = TimeTrace.getTime(); + long start = TimeLog.getTime(); E result = WikittyUtil.newInstance( securityToken, wikittyService, target, ((BusinessEntityImpl)source).getWikitty()); - timeTrace.add(start, "cast"); + timeLog.log(start, "cast"); return result; } @@ -178,12 +177,12 @@ } public Wikitty store(Wikitty w) { - long start = TimeTrace.getTime(); + long start = TimeLog.getTime(); WikittyEvent resp = wikittyService.store(securityToken, w); // update object resp.update(w); - timeTrace.add(start, "store"); + timeLog.log(start, "store"); return w; } @@ -196,7 +195,7 @@ * @return updated objects list */ public <E extends BusinessEntity> List<E> store(List<E> objets) { - long start = TimeTrace.getTime(); + long start = TimeLog.getTime(); // prepare data to send to service List<Wikitty> wikitties = new ArrayList<Wikitty>(objets.size()); for (E e : objets) { @@ -212,12 +211,12 @@ resp.update(w); } - timeTrace.add(start, "store<list>"); + timeLog.log(start, "store<list>"); return objets; } public List<Wikitty> storeWikitty(List<Wikitty> wikitties) { - long start = TimeTrace.getTime(); + long start = TimeLog.getTime(); // call the service with Wikitty WikittyEvent resp = wikittyService.store(securityToken, wikitties); @@ -227,7 +226,7 @@ resp.update(w); } - timeTrace.add(start, "storeWikitty<list>"); + timeLog.log(start, "storeWikitty<list>"); return wikitties; } @@ -243,7 +242,7 @@ */ public <E extends BusinessEntity> E restore(Class<E> clazz, String id, boolean checkExtension) { try { - long start = TimeTrace.getTime(); + long start = TimeLog.getTime(); E result = null; if (id != null) { HashSet<String> extNames = null; @@ -274,7 +273,7 @@ } } - timeTrace.add(start, "restore<Business>"); + timeLog.log(start, "restore<Business>"); return result; } catch (SecurityException eee) { throw eee; @@ -290,13 +289,13 @@ * @return wikitty entity with specified id or {@code null} if entity can't be found */ public Wikitty restore(String id) { - long start = TimeTrace.getTime(); + long start = TimeLog.getTime(); Wikitty result = null; if (id != null) { result = wikittyService.restore(securityToken, id); } - timeTrace.add(start, "restore"); + timeLog.log(start, "restore"); return result; } @@ -320,11 +319,11 @@ * @return wikitty entity with specified id or {@code null} if entity can't be found */ public List<Wikitty> restore(List<String> id) { - long start = TimeTrace.getTime(); + long start = TimeLog.getTime(); List<Wikitty> result = wikittyService.restore(securityToken, id); - timeTrace.add(start, "restoreWikitty<list>"); + timeLog.log(start, "restoreWikitty<list>"); return result; } @@ -341,7 +340,7 @@ */ public <E extends BusinessEntity> List<E> restore( Class<E> clazz, List<String> id, boolean checkExtension) { - long start = TimeTrace.getTime(); + long start = TimeLog.getTime(); List<Wikitty> wikitties = wikittyService.restore(securityToken, id); List<E> result = new ArrayList<E>(); @@ -375,7 +374,7 @@ result.add(dto); } - timeTrace.add(start, "restore<list>"); + timeLog.log(start, "restore<list>"); return result; } @@ -385,30 +384,30 @@ } public void delete(String id) { - long start = TimeTrace.getTime(); + long start = TimeLog.getTime(); wikittyService.delete(securityToken, id); - timeTrace.add(start, "delete"); + timeLog.log(start, "delete"); } public <E extends BusinessEntity> void delete(E object) { - long start = TimeTrace.getTime(); + long start = TimeLog.getTime(); if (object != null) { String id = object.getWikittyId(); wikittyService.delete(securityToken, id); } - timeTrace.add(start, "delete(BusinessEntity)"); + timeLog.log(start, "delete(BusinessEntity)"); } public void delete(Collection<String> ids) { - long start = TimeTrace.getTime(); + long start = TimeLog.getTime(); wikittyService.delete(securityToken, ids); - timeTrace.add(start, "delete<list>"); + timeLog.log(start, "delete<list>"); } public <E extends BusinessEntity> void delete(List<E> objets) { - long start = TimeTrace.getTime(); + long start = TimeLog.getTime(); // prepare data to send to service List<String> ids = new ArrayList<String>(objets.size()); @@ -422,7 +421,7 @@ // call the service with Wikitty wikittyService.delete(securityToken, ids); - timeTrace.add(start, "delete<list<BusinessEntity>>"); + timeLog.log(start, "delete<list<BusinessEntity>>"); } /** @@ -436,7 +435,7 @@ */ public <E extends BusinessEntityImpl> PagedResult<E> findAllByExample(E e, int firstIndex, int endIndex, String ... fieldFacet ) { - long start = TimeTrace.getTime(); + long start = TimeLog.getTime(); Criteria criteria = Search.query(e.getWikitty()).criteria() .setFirstIndex(firstIndex).setEndIndex(endIndex) @@ -449,7 +448,7 @@ PagedResult<E> result = (PagedResult<E>)pagedResult.cast( this, e.getClass(), true); - timeTrace.add(start, "findAllByExample<limit>"); + timeLog.log(start, "findAllByExample<limit>"); return result; } @@ -460,7 +459,7 @@ * @return */ public <E extends BusinessEntityImpl> E findByExample(E e) { - long start = TimeTrace.getTime(); + long start = TimeLog.getTime(); Criteria criteria = Search.query(e.getWikitty()).criteria(); String id = wikittyService.findByCriteria(securityToken, criteria); @@ -471,7 +470,7 @@ securityToken, wikittyService, e.getClass(), w); } - timeTrace.add(start, "findByExample"); + timeLog.log(start, "findByExample"); return result; } @@ -487,7 +486,7 @@ */ public <E extends BusinessEntity> PagedResult<E> findAllByCriteria( Class<E> clazz, Criteria criteria) { - long start = TimeTrace.getTime(); + long start = TimeLog.getTime(); // newInstance only return BusinessEntityWikittyImpl BusinessEntityImpl sample = @@ -543,24 +542,24 @@ PagedResult<E> result = (PagedResult<E>)pagedResult.cast( this, sample.getClass(), true); - timeTrace.add(start, "findAllByCriteria<Business>"); + timeLog.log(start, "findAllByCriteria<Business>"); return result; } public PagedResult<Wikitty> findAllByCriteria(Criteria criteria) { - long start = TimeTrace.getTime(); + long start = TimeLog.getTime(); PagedResult<String> resultId = wikittyService.findAllByCriteria(securityToken, criteria); PagedResult<Wikitty> result = resultId.cast(securityToken, wikittyService); - timeTrace.add(start, "findAllByCriteria"); + timeLog.log(start, "findAllByCriteria"); return result; } public PagedResult<String> findAllIdByCriteria(Criteria criteria) { - long start = TimeTrace.getTime(); + long start = TimeLog.getTime(); PagedResult<String> result = wikittyService.findAllByCriteria(securityToken, criteria); - timeTrace.add(start, "findAllByCriteria"); + timeLog.log(start, "findAllByCriteria"); return result; } @@ -583,7 +582,7 @@ */ public TreeNodeResult<Wikitty> findTreeNode( String wikittyId, int depth, boolean count, Criteria filter) { - long start = TimeTrace.getTime(); + long start = TimeLog.getTime(); TreeNodeResult<String> resultId = wikittyService.findTreeNode( securityToken, wikittyId, depth, count, filter); @@ -603,7 +602,7 @@ resultId.acceptVisitor(convertVisitor); TreeNodeResult<Wikitty> result = convertVisitor.getTree(); - timeTrace.add(start, "findTreeNode<Wikitty>"); + timeLog.log(start, "findTreeNode<Wikitty>"); return result; } @@ -626,7 +625,7 @@ public <E extends BusinessEntity> TreeNodeResult<E> findTreeNode( Class<E> clazz, String wikittyId, int depth, boolean count, Criteria filter) { - long start = TimeTrace.getTime(); + long start = TimeLog.getTime(); TreeNodeResult<String> resultId = wikittyService.findTreeNode( securityToken, wikittyId, depth, count, filter); @@ -646,7 +645,7 @@ resultId.acceptVisitor(convertVisitor); TreeNodeResult<E> result = convertVisitor.getTree(); - timeTrace.add(start, "findTreeNode"); + timeLog.log(start, "findTreeNode"); return result; } @@ -771,16 +770,16 @@ */ public TreeNodeResult<String> findAllIdTreeNode( String wikittyId, int depth, boolean count, Criteria filter) { - long start = TimeTrace.getTime(); + long start = TimeLog.getTime(); TreeNodeResult<String> result = wikittyService.findTreeNode( securityToken, wikittyId, depth, count, filter); - timeTrace.add(start, "findAllIdTreeNode"); + timeLog.log(start, "findAllIdTreeNode"); return result; } public <E extends BusinessEntity> E findByCriteria(Class<E> clazz, Criteria criteria) { - long start = TimeTrace.getTime(); + long start = TimeLog.getTime(); BusinessEntityImpl sample = (BusinessEntityImpl)WikittyUtil.newInstance(clazz); @@ -796,15 +795,15 @@ E result = WikittyUtil.newInstance( securityToken, wikittyService, clazz, w); - timeTrace.add(start, "findByCriteria<Business>"); + timeLog.log(start, "findByCriteria<Business>"); return result; } public Wikitty findByCriteria(Criteria criteria) { - long start = TimeTrace.getTime(); + long start = TimeLog.getTime(); String id = wikittyService.findByCriteria(securityToken, criteria); Wikitty wikitty = wikittyService.restore(securityToken, id); - timeTrace.add(start, "findByCriteria"); + timeLog.log(start, "findByCriteria"); return wikitty; } @@ -815,10 +814,10 @@ * @return {@true} if at least one node has been deleted */ public WikittyEvent deleteTree(String treeNodeId) { - long start = TimeTrace.getTime(); + long start = TimeLog.getTime(); WikittyEvent result = wikittyService.deleteTree(securityToken,treeNodeId); - timeTrace.add(start, "deleteTree"); + timeLog.log(start, "deleteTree"); return result; } @@ -836,13 +835,13 @@ @Deprecated public <E extends BusinessEntity> Map.Entry<E, Integer> restoreNode( Class<E> clazz, String wikittyId, Criteria filter) { - long start = TimeTrace.getTime(); + long start = TimeLog.getTime(); TreeNodeResult<E> tree = findTreeNode(clazz, wikittyId, 0, true, filter); Map.Entry<E, Integer> result = new SimpleEntry<E, Integer>( tree.getObject(), tree.getAttCount()); - timeTrace.add(start, "restoreNode"); + timeLog.log(start, "restoreNode"); return result; } @@ -879,7 +878,7 @@ @Deprecated public <E extends BusinessEntity> Map<E, Integer> findTreeNode( Class<E> clazz, String wikittyId, Criteria filter) { - long start = TimeTrace.getTime(); + long start = TimeLog.getTime(); TreeNodeResult<E> tree = findTreeNode(clazz, wikittyId, 1, true, filter); @@ -888,7 +887,7 @@ result.put(child.getObject(), child.getAttCount()); } - timeTrace.add(start, "findTreeNode"); + timeLog.log(start, "findTreeNode"); return result; } @@ -907,17 +906,17 @@ } public Wikitty restoreVersion(String wikittyId, String version) { - long start = TimeTrace.getTime(); + long start = TimeLog.getTime(); Wikitty result = wikittyService.restoreVersion( securityToken, wikittyId, version); - timeTrace.add(start, "restoreVersion"); + timeLog.log(start, "restoreVersion"); return result; } public <E extends BusinessEntity> boolean hasType(Class<E> clazz, String wikittyId) { try { - long start = TimeTrace.getTime(); + long start = TimeLog.getTime(); boolean result = true; @@ -943,7 +942,7 @@ } } - timeTrace.add(start, "hasType"); + timeLog.log(start, "hasType"); return result; } catch (SecurityException eee) { throw eee; @@ -960,11 +959,11 @@ * @return update response */ public WikittyEvent storeExtension(WikittyExtension ext) { - long start = TimeTrace.getTime(); + long start = TimeLog.getTime(); WikittyEvent response = wikittyService.storeExtension(securityToken, ext); - timeTrace.add(start, "storeExtension"); + timeLog.log(start, "storeExtension"); return response; } @@ -975,11 +974,11 @@ * @return update response */ public WikittyEvent storeExtension(Collection<WikittyExtension> exts) { - long start = TimeTrace.getTime(); + long start = TimeLog.getTime(); WikittyEvent response = wikittyService.storeExtension(securityToken, exts); - timeTrace.add(start, "storeExtension<list>"); + timeLog.log(start, "storeExtension<list>"); return response; } @@ -990,10 +989,10 @@ * @return the corresponding object, exception if no such object found. */ public WikittyExtension restoreExtension(String extensionId) { - long start = TimeTrace.getTime(); + long start = TimeLog.getTime(); WikittyExtension extension = wikittyService.restoreExtension(securityToken, extensionId); - timeTrace.add(start, "restoreExtension"); + timeLog.log(start, "restoreExtension"); return extension; } @@ -1004,25 +1003,25 @@ * @return the corresponding object, exception if no such object found. */ public WikittyExtension restoreExtensionLastVersion(String extensionName) { - long start = TimeTrace.getTime(); + long start = TimeLog.getTime(); WikittyExtension extension = wikittyService.restoreExtensionLastVersion(securityToken, extensionName); - timeTrace.add(start, "restoreExtensionLastVersion"); + timeLog.log(start, "restoreExtensionLastVersion"); return extension; } public void deleteExtension(String extName) { - long start = TimeTrace.getTime(); + long start = TimeLog.getTime(); wikittyService.deleteExtension(securityToken, extName); - timeTrace.add(start, "deleteExtension"); + timeLog.log(start, "deleteExtension"); } public void deleteExtension(Collection<String> extNames) { - long start = TimeTrace.getTime(); + long start = TimeLog.getTime(); wikittyService.deleteExtension(securityToken, extNames); - timeTrace.add(start, "deleteExtension<list>"); + timeLog.log(start, "deleteExtension<list>"); } /** @@ -1031,10 +1030,10 @@ * @return extension id list */ public List<String> getAllExtensionIds() { - long start = TimeTrace.getTime(); + long start = TimeLog.getTime(); List<String> result = wikittyService.getAllExtensionIds(securityToken); - timeTrace.add(start, "getAllExtensionIds"); + timeLog.log(start, "getAllExtensionIds"); return result; } @@ -1046,10 +1045,10 @@ * @return extensions */ public List<String> getAllExtensionsRequires(String extensionName) { - long start = TimeTrace.getTime(); + long start = TimeLog.getTime(); List<String> result = wikittyService.getAllExtensionsRequires(securityToken, extensionName); - timeTrace.add(start, "getAllExtensionsRequires"); + timeLog.log(start, "getAllExtensionsRequires"); return result; } @@ -1058,10 +1057,10 @@ * This operation should be disabled in production environment. */ public WikittyEvent clear() { - long start = TimeTrace.getTime(); + long start = TimeLog.getTime(); WikittyEvent result = wikittyService.clear(securityToken); - timeTrace.add(start, "clear"); + timeLog.log(start, "clear"); return result; } @@ -1070,10 +1069,10 @@ * reindex all object. */ public void syncSearchEngine() { - long start = TimeTrace.getTime(); + long start = TimeLog.getTime(); wikittyService.syncSearchEngine(securityToken); - timeTrace.add(start, "syncSearchEngine"); + timeLog.log(start, "syncSearchEngine"); } /** @@ -1082,10 +1081,10 @@ * @return the wikitty encapsulated */ public Wikitty getWikitty(BusinessEntity entity){ - long start = TimeTrace.getTime(); + long start = TimeLog.getTime(); Wikitty result = WikittyUtil.getWikitty(wikittyService, securityToken, entity); - timeTrace.add(start, "getWikitty"); + timeLog.log(start, "getWikitty"); return result; } @@ -1096,7 +1095,7 @@ * @return true is the logged in user is in the group */ public boolean isMember(String groupName) { - long start = TimeTrace.getTime(); + long start = TimeLog.getTime(); boolean result = false; WikittyUser user = getLoggedInUser(); @@ -1114,7 +1113,7 @@ user.getWikittyId(), group.getId()); } - timeTrace.add(start, "isMember"); + timeLog.log(start, "isMember"); return result; } @@ -1124,14 +1123,14 @@ * @return the logged in #WikittyUser */ public WikittyUser getLoggedInUser() { - long start = TimeTrace.getTime(); + long start = TimeLog.getTime(); String userId = WikittySecurityUtil.getUserForToken(wikittyService, securityToken); WikittyUser user = restore(WikittyUser.class, userId); - timeTrace.add(start, "getLoggedInUser"); + timeLog.log(start, "getLoggedInUser"); return user; }

1 0

r720 - trunk/wikitty-jdbc-impl/src/main/java/org/nuiton/wikitty/jdbc
by echatellier＠users.nuiton.org 23 Feb '11

23 Feb '11

Author: echatellier Date: 2011-02-23 11:01:28 +0100 (Wed, 23 Feb 2011) New Revision: 720 Url: http://nuiton.org/repositories/revision/wikitty/720 Log: Fix exception text Modified: trunk/wikitty-jdbc-impl/src/main/java/org/nuiton/wikitty/jdbc/WikittyStorageJDBC.java Modified: trunk/wikitty-jdbc-impl/src/main/java/org/nuiton/wikitty/jdbc/WikittyStorageJDBC.java =================================================================== --- trunk/wikitty-jdbc-impl/src/main/java/org/nuiton/wikitty/jdbc/WikittyStorageJDBC.java 2011-02-22 18:57:43 UTC (rev 719) +++ trunk/wikitty-jdbc-impl/src/main/java/org/nuiton/wikitty/jdbc/WikittyStorageJDBC.java 2011-02-23 10:01:28 UTC (rev 720) @@ -475,7 +475,7 @@ scanner.scan(id); } } catch (SQLException eee) { - throw new WikittyException("Can't scan wall wikitty", eee); + throw new WikittyException("Can't scan whole wikitty", eee); } finally { WikittyJDBCUtil.closeQuietly(connection); }

1 0