Changeset 980 for MDService2/trunk/MDService2/src/eu/clarin/cmdi/mdservice/action/Cache.java

Timestamp:

12/10/10 22:05:19 (13 years ago)

Author:

gaba

Message:

admin/cache/del - created, notifyUser-messages

File:

• MDService2/trunk/MDService2/src/eu/clarin/cmdi/mdservice/action/Cache.java (modified) (4 diffs)

MDService2/trunk/MDService2/src/eu/clarin/cmdi/mdservice/action/Cache.java

@@ -15 +15 @@
 */
 import java.util.Date;
+import java.util.HashMap;
 import java.text.DateFormat;
 import java.text.SimpleDateFormat;
@@ -171 +172 @@
                 }
                 
-                DateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd:hh-mm-ss");
+                DateFormat dateFormat = new SimpleDateFormat("yyyy-MM-ddThh:mm:ss");
                 e.setAttribute("date", dateFormat.format(new Date()).toString());
                 cacheindex_doc.getFirstChild().appendChild(e);
@@ -235 +236 @@
                 return transformed;
         }
+        
         
          //TODO: sanitize-key
@@ -506 +508 @@
                 */
         }
+        
+        public InputStream clear(HashMap<String,String> clear_params) throws ParserConfigurationException, TransformerConfigurationException, TransformerException, TransformerFactoryConfigurationError {
+                String xpath_expr = "";
+                Integer removed = 0;
+                InputStream is = null;
+                
+                if (clear_params.size() > 0 ) {
+                        if (clear_params.containsKey("repository")){
+                                xpath_expr = xpath_expr + " and @repository='" + clear_params.get("repository") + "'";
+                        }
+                        if (clear_params.containsKey("type")){
+                                xpath_expr = xpath_expr + " and @type='" + clear_params.get("type") + "'";
+                        }
+                        if (clear_params.containsKey("date")){
+                                xpath_expr = xpath_expr + " and @date='" + clear_params.get("date") + "'";
+                        }
+                        if (clear_params.containsKey("datefrom")){
+                                xpath_expr = xpath_expr + " and @date >= '" + clear_params.get("datefrom") + "'";
+                        }
+                        if (clear_params.containsKey("dateto")){
+                                xpath_expr = xpath_expr + " and @date <= '" + clear_params.get("dateto") + "'";
+                        }
+                        if (xpath_expr.length()>0){
+                                xpath_expr = xpath_expr.substring(5);
+                        }
+                        xpath_expr = "//index/f[" + xpath_expr + "]";
+                } else {
+                        xpath_expr = "//index/f";
+                }
+        
+                ////////// remove index_lines  + files
+                String id,type,path;
+                File f;
+                //creating an XPathFactory:
+                XPathFactory factory = XPathFactory.newInstance();
+                //using this factory to create an XPath object: 
+                XPath xpath = factory.newXPath();
+                //XPath object created compiles the XPath expression: 
+                XPathExpression expr;
+                try {
+                        expr = xpath.compile(xpath_expr);
+                        //expression is evaluated with respect to a certain context node which is doc.
+                Object result = expr.evaluate(cacheindex_doc, XPathConstants.NODESET);
+                NodeList list = (NodeList) result;
+                
+                //create deleted_doc
+                DocumentBuilderFactory docFactory = DocumentBuilderFactory.newInstance();
+                DocumentBuilder docBuilder;
+                        docBuilder = docFactory.newDocumentBuilder();
+                        Document deleted_doc = docBuilder.newDocument();
+                        Element root = (Element) deleted_doc.createElement("index");
+                        root.setAttribute("count_deleted", String.valueOf(list.getLength()) );
+                        deleted_doc.appendChild(root);
+                        
+                        // delete items
+                        for(int i = 0;i< list.getLength();i++){
+                                
+                                id = list.item(i).getAttributes().getNamedItem("id").getNodeValue();
+                        type = list.item(i).getAttributes().getNamedItem("type").getNodeValue();
+                        path = cachepath + PREFIX + type + "_"+id + ".xml";
+                        f = new File (path);
+                        
+                        f.delete();
+                        cacheindex_doc.getFirstChild().removeChild(list.item(i));
+                        
+                        Element e = deleted_doc.createElement("f");
+                        e.setAttribute("filename", path);
+                        e.setAttribute("id", id);
+                        deleted_doc.getFirstChild().appendChild(e);
+                        }  
+                        
+                        //create resultstream
+                        ByteArrayOutputStream outputStream = new ByteArrayOutputStream(); 
+                        Source xmlSource = new DOMSource(deleted_doc); 
+                        Result outputTarget = new StreamResult(outputStream); 
+                        TransformerFactory.newInstance().newTransformer().transform(xmlSource, outputTarget); 
+                        is = new ByteArrayInputStream(outputStream.toByteArray()); 
+
+                        removed = list.getLength();
+                
+                } catch (XPathExpressionException e) {
+                        // TODO Auto-generated catch block
+                        e.printStackTrace();
+                }
+                
+                //////// set the index value
+                NodeList nl = cacheindex_doc.getElementsByTagName("f");
+                if (nl.getLength() < 1){
+                        cachecounter = 1;
+                }else {
+                        cachecounter = Integer.parseInt(nl.item(nl.getLength()-1).getAttributes().getNamedItem("id").getNodeValue());
+                }
+                this.updateCachecounter();
+                return is;
+        }
+
 }