coordinationinitialiser.java

一个完整的XACML工程,学习XACML技术的好例子!

/*
* Copyright (c) 2006, University of Kent
* All rights reserved.
*
* Redistribution and use in source and binary forms, with or without 
* modification, are permitted provided that the following conditions are met:
*
* Redistributions of source code must retain the above copyright notice, this 
* list of conditions and the following disclaimer.
* 
* Redistributions in binary form must reproduce the above copyright notice, 
* this list of conditions and the following disclaimer in the documentation 
* and/or other materials provided with the distribution. 
*
* 1. Neither the name of the University of Kent nor the names of its 
* contributors may be used to endorse or promote products derived from this 
* software without specific prior written permission. 
*
* 2. THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS  
* IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO,
* THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR 
* PURPOSE ARE DISCLAIMED. 
*
* 3. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE 
* LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR 
* CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF 
* SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS 
* INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN 
* CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) 
* ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE 
* POSSIBILITY OF SUCH DAMAGE.
*
* 4. YOU AGREE THAT THE EXCLUSIONS IN PARAGRAPHS 2 AND 3 ABOVE ARE REASONABLE
* IN THE CIRCUMSTANCES.  IN PARTICULAR, YOU ACKNOWLEDGE (1) THAT THIS
* SOFTWARE HAS BEEN MADE AVAILABLE TO YOU FREE OF CHARGE, (2) THAT THIS
* SOFTWARE IS NOT "PRODUCT" QUALITY, BUT HAS BEEN PRODUCED BY A RESEARCH
* GROUP WHO DESIRE TO MAKE THIS SOFTWARE FREELY AVAILABLE TO PEOPLE WHO WISH
* TO USE IT, AND (3) THAT BECAUSE THIS SOFTWARE IS NOT OF "PRODUCT" QUALITY
* IT IS INEVITABLE THAT THERE WILL BE BUGS AND ERRORS, AND POSSIBLY MORE
* SERIOUS FAULTS, IN THIS SOFTWARE.
*
* 5. This license is governed, except to the extent that local laws
* necessarily apply, by the laws of England and Wales.
*/
/*
 * CoordinationAttribute.java
 *
 * Created on 14 June 2006, 12:56
 *
 * To change this template, choose Tools | Template Manager
 * and open the template in the editor.
 */

package uk.ac.kent.dpa.coord.database;

import java.sql.*;
import javax.xml.parsers.*;
import org.w3c.dom.*;
import java.util.*;
import uk.ac.kent.dpa.mysql.init.DatabaseException;
import uk.ac.kent.dpa.mysql.init.DbInitial;
/**
 *
 * @author ls97
 */
public class CoordinationInitialiser {

    private String configurationFileName;
    
    /** Creates a new instance of CoordinationAttribute */
    public CoordinationInitialiser(String configIn) {
        this.configurationFileName = configIn;
    }
    /**
     * given the CAD table, this method creates coordination attribute tables
     * param@ CAD table name i.e. CADTable
     */
    public void createCoordinationAttributeTable(String cadtName) throws CoordDatabaseException {
        ArrayList triples = new ArrayList();
        try {
            DbInitial db = new DbInitial(this.getConfigurationFileName());
            String sql;
            sql = "SELECT Name, Id, AttributeDefinition FROM "+cadtName+";";
            ResultSet sqlResults = db.getConnection().executeQuery(sql);
            while (sqlResults.next()) {
                String coordName = sqlResults.getString("Name");
                String coordId = sqlResults.getString("Id");
                String defining = sqlResults.getString("AttributeDefinition");
                XMLParser parser = new XMLParser(defining);
                Element msg = parser.getXmlElement();
                NameIdDefiningTriple triple = new NameIdDefiningTriple(coordName,coordId,msg);
                triples.add(triple);
            }
            try{db.getConnection().close();} catch (Exception e){};
            try{db.getDB().setAutoCommit(true);} catch (Exception e){};
            try{db.getDB().close();} catch (Exception e){};
            for (Iterator i=triples.iterator();i.hasNext();) {
                NameIdDefiningTriple triple = (NameIdDefiningTriple)i.next();
                String dbURL = new String();
                String coordName = triple.getName();
                String coordId = triple.getId();
                Element msg = triple.getDefining();
                int index1 = coordName.indexOf("//");
                int index2 = coordName.lastIndexOf("/");
                db = null;
                if (index2-index1>2) {
                    dbURL = coordName.substring(index1,index2);
                    db = new DbInitial(this.getConfigurationFileName(),dbURL);
                } else db = new DbInitial(this.getConfigurationFileName());
                this.createDataTable(db,msg,coordId);
                try{db.getConnection().close();} catch (Exception e){};
                try{db.getDB().setAutoCommit(true);} catch (Exception e){};
                try{db.getDB().close();} catch (Exception e){};
            }
        } catch (DatabaseException de) {
            throw new CoordDatabaseException("DB cannot be initialised:"+de);
        } catch (SQLException se) {
            throw new CoordDatabaseException("SQL operation error:"+se);
        }
    }

    public String getConfigurationFileName() {
        return configurationFileName;
    }
    
    private void createDataTable(DbInitial dbIn,Element msg,String tableName) throws CoordDatabaseException {
        String sql;
        sql = "create table "+tableName+" (";
        String dataType = null;
        NamedNodeMap map = msg.getAttributes();
        for (int i=0; i<map.getLength(); i++) {
            Node node = map.item(i);
            if (node.getNodeName().equals("DataType")) {
                dataType = node.getNodeValue();
                break;
            }
        }
        if (dataType==null) throw new CoordDatabaseException("illigal defining XML");
        NodeList list = msg.getChildNodes();
        for (int i=0; i<list.getLength(); i++) {
            Node node = list.item(i);
            if (node.getNodeName().equals("attribute")) {
                String name = null;
                String type = null;
                NamedNodeMap map1 = node.getAttributes();
                for (int j=0; j<map1.getLength(); j++) {
                    Node node1 = map1.item(j);
                    if (node1.getNodeName().equals("Name")) {
                        name = node1.getNodeValue();
                    } else if (node1.getNodeName().equals("DataType")) {
                        type = node1.getNodeValue();
                    }
                }
                if (node.getChildNodes().getLength()>0) {
                    NodeList list1 = node.getChildNodes();
                    for (int j=0; j<list1.getLength(); j++) {
                        Node node1 = list1.item(j);
                        if (node1.getNodeName().equals("variable")) {
                            NamedNodeMap map2 = node1.getAttributes();
                            for (int k=0; k<map2.getLength(); k++) {
                                Node node2 = map2.item(k);
                                if (node2.getNodeName().equals("Name")) {
                                    name = node2.getNodeValue();
                                }
                            }
                        }
                    }
                } 
                if (name==null || type ==null) throw new CoordDatabaseException("illigal defining XML");
                name = name.replaceAll(":","_");
                while (name.indexOf(".")>=0)name = name.replace(".","_");
                name = name.replace("(","1");
                name = name.replace(")","1");
                while (name.indexOf("-")>=0) name = name.replace("-","_");
                sql += name+" ";
                if (type.equals("http://www.w3.org/2001/XMLSchema#integer")) sql +="INT, ";
                else if (type.equals("http://www.w3.org/2001/XMLSchema#double")) sql +="FLOAT, ";
                else sql += "TEXT, ";
            }
        }
        sql += "Value ";
        if (dataType.equals("http://www.w3.org/2001/XMLSchema#integer")) sql +="INT);";
        else if (dataType.equals("http://www.w3.org/2001/XMLSchema#double")) sql +="FLOAT);";
        else sql += "TEXT);";
        try {
            dbIn.getConnection().executeUpdate(sql);
            } catch(SQLException sqle) {
            throw new CoordDatabaseException("Warnning: couldn't create coordination attribute distribution table: the error was: " + sqle);
        };
    }
    
}