dbcmd.java

Jena推理机

/*
 * (c) Copyright 2003, 2004, 2005, 2006, 2007 Hewlett-Packard Development Company, LP
 * [See end of file]
 */

 
package jena.util;
import jena.cmdline.* ;
import com.hp.hpl.jena.db.* ;
import com.hp.hpl.jena.enhanced.BuiltinPersonalities;
import com.hp.hpl.jena.rdf.model.Model;
//import com.hp.hpl.jena.rdf.model.* ;
import java.util.* ;
 
/** Framework for the database commands.
 * 
 * @author Andy Seaborne
 * @version $Id: DBcmd.java,v 1.5 2007/01/02 11:54:10 andy_seaborne Exp $
 */ 
 
public abstract class DBcmd
{
    // Standardised names.
    protected final ArgDecl argDeclDbURL       = new ArgDecl(true, "db");
    protected final ArgDecl argDeclDbType      = new ArgDecl(true, "dbType");
    protected final ArgDecl argDeclDbUser      = new ArgDecl(true, "dbUser", "user");
    protected final ArgDecl argDeclDbPassword  = new ArgDecl(true, "dbPassword", "password", "pw");
    protected final ArgDecl argDeclModelName   = new ArgDecl(true, "model");
    protected final ArgDecl argDeclDbDriver    = new ArgDecl(true, "driver");

    protected final ArgDecl argDeclVerbose     = new ArgDecl(false, "v", "verbose");
    protected boolean verbose = false ;

    protected final ArgDecl argDeclDebug       = new ArgDecl(false, "debug");
    protected boolean debug = false ;

    protected final ArgDecl argDeclHelp        = new ArgDecl(false, "help", "h");


    // The values of these arguments
    protected String argDbURL = null;
    protected String argDbType = null;          // Lower-cased name - key into tables
    protected String argDriverName = null;      // JDBC class name
    protected String argDriverTypeName = null;  // Jena driver name
    protected String argDbUser = null;
    protected String argDbPassword = null;
    protected String argModelName = null;

    // DB types to JDBC driver name (some common choices)
    private static Map jdbcDrivers = new HashMap();
    static {
        jdbcDrivers.put("mysql",       "com.mysql.jdbc.Driver");
        jdbcDrivers.put("mssql",       "com.microsoft.jdbc.sqlserver.SQLServerDriver") ;      // What's the best coice here?
        jdbcDrivers.put("postgres",    "org.postgresql.Driver");
        jdbcDrivers.put("postgresql",  "org.postgresql.Driver");
    }
    
    // DB types to name Jena uses internally
    private static Map jenaDriverName = new HashMap();
    static {
        jenaDriverName.put("mssql",       "MsSQL");
        jenaDriverName.put("mysql",       "MySQL");
        jenaDriverName.put("postgresql",  "PostgreSQL");
        jenaDriverName.put("postgres",    "PostgreSQL");
        jenaDriverName.put("oracle",      "Oracle");
    }

    boolean takesPositionalArgs = false ;
    String cmdName = "DB" ;
    CommandLine cmdLine = new CommandLine();
    private IDBConnection jdbcConnection = null;
    private ModelRDB dbModel = null ;
    
    private String [] usage = new String[]{ "Complain to jena-dev: someone forgot the usage string" } ;

    protected DBcmd(String n, boolean posArgs)
    {
        cmdName = n ;
        takesPositionalArgs = posArgs ;
        cmdLine.add(argDeclDbURL);
        cmdLine.add(argDeclDbType);
        cmdLine.add(argDeclDbUser);
        cmdLine.add(argDeclDbPassword);
        cmdLine.add(argDeclModelName);
        cmdLine.add(argDeclVerbose) ;
        cmdLine.add(argDeclDebug) ;
        cmdLine.add(argDeclHelp) ;
    }

    protected CommandLine getCommandLine() { return cmdLine ; } 
    
    protected void init(String[] args)
    {
        try {
            cmdLine.process(args);
        } catch (IllegalArgumentException ex)
        {
            usage() ;
            System.exit(1) ;
        }
        
        if ( cmdLine.contains(argDeclHelp) )
        {
            usage() ;
            System.exit(0) ;
        }
        
        verbose = cmdLine.contains(argDeclVerbose) ;
        debug = cmdLine.contains(argDeclDebug) ;
        if ( debug )
            verbose = true ;
        
        if (cmdLine.contains(argDeclDbURL))
            argDbURL = cmdLine.getArg(argDeclDbURL).getValue();

        if (cmdLine.contains(argDeclDbType))
            argDbType = cmdLine.getArg(argDeclDbType).getValue();

        if (cmdLine.contains(argDeclDbUser))
            argDbUser = cmdLine.getArg(argDeclDbUser).getValue();

        if (cmdLine.contains(argDeclDbPassword))
            argDbPassword = cmdLine.getArg(argDeclDbPassword).getValue();

        if (cmdLine.contains(argDeclModelName))
            argModelName = cmdLine.getArg(argDeclModelName).getValue();

        if ( verbose )
        {
            System.out.println("URL       = " + argDbURL);
            System.out.println("User      = " + argDbUser);
            System.out.println("Password  = " + argDbPassword);
            System.out.println("Type      = " + argDbType);
            System.out.println("Name      = " + argModelName);
        }

        // Mandatory arguments
        if (argDbURL == null || argDbType == null || argDbUser == null || argDbPassword == null)
        {
            System.err.println("Missing a required argument (need JDBC URL, user, password and DB type)");
            System.exit(9);
        }

        if ( ! takesPositionalArgs && cmdLine.numItems() != 0 )
        {
            System.err.println(cmdName+": No positional arguments allowed") ;
            usage() ;
            System.exit(9) ;
        }
        
        if ( takesPositionalArgs && cmdLine.numItems() == 0 )
        {
            System.err.println(cmdName+": Positional argument required") ;
            usage() ;
            System.exit(9) ;
        }

        // Canonical form (for DBcmd)
        argDbType = argDbType.toLowerCase() ;
        argDriverName = (String)jdbcDrivers.get(argDbType);
        argDriverTypeName = (String)jenaDriverName.get(argDbType) ;
        
        if (cmdLine.contains(argDeclDbDriver))
            argDriverName = cmdLine.getArg(argDeclDbDriver).getValue();

        if (argDriverName == null)
        {
            System.err.println("No driver: please say which JDBC driver to use");
            System.exit(9);
        }

        try
        {
            Class.forName(argDriverName);
        }
        catch (Exception ex)
        {
            System.err.println("Couldn't load the driver class: " + argDriverName);
            System.err.println("" + ex);
            System.exit(9);
        }

    }
    
    protected ModelRDB getRDBModel() 
    {
        if ( dbModel == null )
        {
            Model m = makeModel() ;
            if ( m instanceof ModelRDB )
                dbModel = (ModelRDB)m ;
            else
            {
                System.out.println("Model maker didn't return a ModleRDB: ("+m.getClass()+")") ;
                System.exit(9) ;
            }
        }
        return dbModel ;   
    }

    private ModelRDB makeModel()
    {
        try 
        {
            // Want a ModelRDB and not the default reificiation mode.
            if ( argModelName != null && argModelName.equals("DEFAULT") )
                argModelName = null ;
            GraphRDB graph = new GraphRDB(getConnection(),
                                          argModelName, null, 
                                          GraphRDB.OPTIMIZE_AND_HIDE_FULL_AND_PARTIAL_REIFICATIONS,
                                          false);
            return new ModelRDB(BuiltinPersonalities.model, graph);
        }
        catch (com.hp.hpl.jena.db.RDFRDBException dbEx)
        {
            Throwable t = dbEx.getCause() ;
            if ( t == null )
                t = dbEx ;
            System.out.println("Failed to connect to the database: "+t.getMessage()) ;
            System.exit(9) ;
            return null ;
        }
    }
        
    protected IDBConnection getConnection()
    {
        if ( jdbcConnection == null )
        {
            try {
                jdbcConnection = new DBConnection(argDbURL, argDbUser, argDbPassword, argDriverTypeName);
            } catch (Exception ex)
            {
                System.out.println("Exception making connection: "+ex.getMessage()) ;
                System.exit(9) ;
            }
        }
        return jdbcConnection ;
    }


    protected void exec()
    {
        if ( cmdLine.numItems() == 0 )
        {
            exec0() ;
            return ;
        }
        
        
        boolean inTransaction = false ;
        try
        {
            for ( int i = 0 ; i < cmdLine.numItems() ; i++ )
            {
                if ( getRDBModel().supportsTransactions() )
                {
                    if ( ! inTransaction )
                    {
                        inTransaction = true ;
                        getRDBModel().begin() ;
                    }
                }

                String arg = cmdLine.getItem(i) ;
                boolean contTrans = false ;
                try {
                    contTrans = exec1(arg) ;
                }
                catch (Exception ex)
                {
                    System.out.println(ex.getMessage()) ;
                    ex.printStackTrace(System.out) ;
                    if ( inTransaction )
                    {
                        getRDBModel().abort() ;
                        inTransaction = false ;
                    }
                    dbModel.close() ;
                    dbModel = null ;
                    System.exit(9);
                }
                    
                if ( !contTrans && inTransaction )
                    getRDBModel().commit() ;
            }
        }            
        finally
        {
            if ( inTransaction )
                getRDBModel().commit() ;
        }
        
        dbModel.close() ;
        dbModel = null ;
    }

    /** Called if there are no psoitional arguments
     */     
    protected abstract void exec0() ;
    
    /** Called for each postional argument, inside a transaction.
     *  Return true to continue this transaction, false to end it and start a new
     *  one if there are any more args 
     */     
    protected abstract boolean exec1(String arg) ;
    
    
    
    protected void setUsage(String a)
    {
        String[] aa = new String[]{a} ;
        setUsage(aa) ;
    } 


    /** Usage message: one line per entry*/
    
    protected void setUsage(String[] a)
    {
        usage = a ;
    }
    
    protected void usage()
    {
        for ( int i = 0 ; i < usage.length ; i++ )
        {
            System.err.println(usage[i]) ;
        }
    }
}

/*
 *  (c) Copyright 2003, 2004, 2005, 2006, 2007 Hewlett-Packard Development Company, LP
 *  All rights reserved.
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions
 * are met:
 * 1. Redistributions of source code must retain the above copyright
 *    notice, this list of conditions and the following disclaimer.
 * 2. 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.
 * 3. The name of the author may not be used to endorse or promote products
 *    derived from this software without specific prior written permission.
 *
 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``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.
 * IN NO EVENT SHALL THE AUTHOR 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.
 */