sascha@372: package de.intevation.flys.artifacts.services;
sascha@372: 
sascha@372: import java.sql.Connection;
sascha@372: import java.sql.SQLException;
sascha@372: 
sascha@372: import org.w3c.dom.Document;
sascha@372: 
sascha@372: import org.apache.log4j.Logger;
sascha@372: 
sascha@415: import java.util.Map;
sascha@415: import java.util.HashMap;
sascha@415: 
sascha@372: import de.intevation.artifacts.CallMeta;
sascha@966: import de.intevation.artifacts.GlobalContext;
sascha@372: 
sascha@372: import de.intevation.artifactdatabase.DefaultService;
sascha@372: 
sascha@372: import de.intevation.artifacts.common.utils.XMLUtils;
sascha@372: 
sascha@421: import de.intevation.artifacts.common.ArtifactNamespaceContext;
sascha@421: 
sascha@372: import de.intevation.flys.artifacts.services.meta.Builder;
sascha@950: import de.intevation.flys.artifacts.services.meta.DataCage;
sascha@372: 
sascha@372: import de.intevation.flys.backend.SessionHolder;
sascha@372: 
sascha@372: import org.hibernate.Session;
sascha@372: 
sascha@372: import org.hibernate.jdbc.Work;
sascha@372: 
sascha@372: public class MetaDataService
sascha@372: extends      DefaultService
sascha@372: {
sascha@372:     private static Logger log = Logger.getLogger(MetaDataService.class);
sascha@372: 
sascha@969:     // old service. To be removed
sascha@421:     public static final String XPATH_RIVER = "/art:river/text()";
sascha@415: 
sascha@969:     public static final String XPATH_OUT  = "/art:out/@value";
sascha@969:     public static final String XPATH_UUID = "/art:uuid/@value";
sascha@969: 
sascha@372:     public MetaDataService() {
sascha@372:     }
sascha@372: 
sascha@415:     protected static Map<String, Object> extractParameters(Document data) {
sascha@415:         HashMap<String, Object> parameters = new HashMap<String, Object>();
sascha@415: 
sascha@421:         String river = XMLUtils.xpathString(
sascha@421:             data, XPATH_RIVER, ArtifactNamespaceContext.INSTANCE);
sascha@415: 
sascha@415:         if (river == null || (river = river.trim()).length() == 0) {
sascha@415:             river = "%"; // matches all rivers
sascha@415:         }
sascha@415: 
sascha@415:         parameters.put("river", river);
sascha@415: 
sascha@415:         return parameters;
sascha@415:     }
sascha@415: 
sascha@372:     @Override
sascha@372:     public Document process(
sascha@966:         Document      data,
sascha@966:         GlobalContext globalContext,
sascha@966:         CallMeta      callMeta
sascha@372:     ) {
sascha@372:         log.debug("MetaDataService.process");
sascha@372: 
sascha@372:         final Document result = XMLUtils.newDocument();
sascha@372: 
sascha@950:         final Builder builder = DataCage.getInstance().getBuilder();
sascha@950: 
sascha@372:         if (builder == null) {
sascha@372:             log.error("MetaDataService is not setup properly.");
sascha@372:             return result;
sascha@372:         }
sascha@372: 
sascha@415:         final Map<String, Object> parameters = extractParameters(data);
sascha@415: 
sascha@372:         Session session = SessionHolder.acquire();
sascha@372:         try {
sascha@372:             session.doWork(new Work() {
sascha@372:                 @Override
sascha@372:                 public void execute(Connection connection)
sascha@372:                 throws SQLException
sascha@372:                 {
sascha@372:                     log.debug("MetaDataService.execute");
sascha@415:                     builder.build(connection, result, parameters);
sascha@372:                 }
sascha@372:             });
sascha@372:         }
sascha@372:         finally {
sascha@372:             session.close();
sascha@372:             SessionHolder.release();
sascha@372:         }
sascha@372: 
sascha@372:         return result;
sascha@372:     }
sascha@372: }
sascha@372: // vim:set ts=4 sw=4 si et sta sts=4 fenc=utf8 :