import mondrian.olap.DriverManager; //导入依赖的package包/类
private static Connection getConnection(String propertiesFileName) throws FileNotFoundException, IOException
{
	if (propertiesFileName == null) {
		throw new RuntimeException("connection properties file not set");
	}
	ConnectionData data = getConnectionData(propertiesFileName);
	Connection connection = null;
	if (data.isEnabled())
	{
		connection = 
			DriverManager.getConnection(
				"Provider=mondrian;" + 
				"JdbcDrivers=" + data.getJdbcDrivers() + ";" +
				"Jdbc=" + data.getJdbcUrl() + ";" +
				"JdbcUser=" + data.getJdbcUser() + ";" +
				"JdbcPassword=" + data.getJdbcPassword() + ";" +
				"Catalog=" + data.getCatalogUri() + ";", 
				null
				);
	}
	return connection;
}
 

import mondrian.olap.DriverManager; //导入依赖的package包/类
@Override
public void contributeParameters(Map<String, Object> parameters)
		throws JRException {
	MondrianDataAdapter mda = getJdbcDataAdapter();
	if (mda != null) {
		Util.PropertyList props = new Util.PropertyList();
		props.put("Catalog", mda.getCatalogURI());
		props.put("Provider", "mondrian");
		props.put("Locale", Locale.getDefault().getLanguage());

		connection = DriverManager.getConnection(props, null,
				new SimpleSQLDataSource(this));

		parameters
				.put(JRMondrianQueryExecuterFactory.PARAMETER_MONDRIAN_CONNECTION,
						connection);
	}
}
 

import mondrian.olap.DriverManager; //导入依赖的package包/类
public OlapConnection getOlap4jConnection() throws SQLException {
    try {
        Class.forName("mondrian.olap4j.MondrianOlap4jDriver");
    } catch (ClassNotFoundException e) {
        throw new RuntimeException("Driver not found");
    }
    String connectString = getConnectString();
    if (connectString.startsWith("Provider=mondrian; ")) {
        connectString =
            connectString.substring("Provider=mondrian; ".length());
    }
    final java.sql.Connection connection =
        java.sql.DriverManager.getConnection(
            "jdbc:mondrian:" + connectString);
    return ((OlapWrapper) connection).unwrap(OlapConnection.class);
}
 

import mondrian.olap.DriverManager; //导入依赖的package包/类
public void openQuery() throws KettleDatabaseException {
    
	String connectString = "Provider=mondrian;" +
        "Jdbc='"+space.environmentSubstitute(databaseMeta.getURL())+"';"+
		"Catalog='"+space.environmentSubstitute(catalog)+"';"+
        "JdbcDrivers="+space.environmentSubstitute(databaseMeta.getDriverClass())+";";
	if (!Const.isEmpty(databaseMeta.getUsername())) {
		connectString+="JdbcUser="+space.environmentSubstitute(databaseMeta.getUsername())+";";
	}
	if (!Const.isEmpty(databaseMeta.getPassword())) {
		connectString+="JdbcPassword="+space.environmentSubstitute(databaseMeta.getPassword())+";";
	}

	connection = DriverManager.getConnection(connectString, null);
    query = connection.parseQuery(queryString);
    result = connection.execute(query);
}
 

import mondrian.olap.DriverManager; //导入依赖的package包/类
@Test
public void loadConvertedSchemaInMondrian() throws Exception {
  // temp file to hold conversion output
  File tmpFile = File.createTempFile("output_foodmart_", ".xml"); //$NON-NLS-1$ //$NON-NLS-2$

  // do conversion on SSAS dump of foodmart
  List<Document> docs = ConversionUtil.generateMondrianDocsFromSSASSchema(getClass().getResourceAsStream(
      "/analysis_server_output.xml")); //$NON-NLS-1$

  // save conversion to file
  FileUtils.writeStringToFile(tmpFile, docs.get(0).asXML());

  // load file into Mondrian
  String connectString = getTestProperty("test.mondrian.foodmart.connectString", //$NON-NLS-1$
      getTestProperty("test.mondrian.foodmart.connectString.provider"), //$NON-NLS-1$
      getTestProperty("test.mondrian.foodmart.connectString.jdbc"), //$NON-NLS-1$
      getTestProperty("test.mondrian.foodmart.connectString.username"), //$NON-NLS-1$
      getTestProperty("test.mondrian.foodmart.connectString.password"), //$NON-NLS-1$
      tmpFile.getPath());

  DriverManager.getConnection(connectString, null).getSchema();
}
 

import mondrian.olap.DriverManager; //导入依赖的package包/类
/**
 * Gets a Mondrian connection, creating a new one if fresh is true.
 *
 * @return mondrian Connection.
 */
public synchronized Connection getConnection(boolean fresh) {
    // FIXME: fresh is currently ignored.
    if (this.connectString == null) {
        makeConnectString();
    }
    if (this.connection == null) {
        this.connection =
            DriverManager.getConnection(this.connectString, null);
    }
    return this.connection;
}
 

import mondrian.olap.DriverManager; //导入依赖的package包/类
/**
 * Gets an olap4j connection, creating a new one if fresh is true.
 *
 * @return mondrian Connection.
 */
public synchronized OlapConnection getOlapConnection() throws SQLException {
    if (this.connectString == null) {
        makeConnectString();
    }
    final String olapConnectString = "jdbc:mondrian:" + connectString;
    final java.sql.Connection jdbcConnection =
        java.sql.DriverManager.getConnection(olapConnectString);
    // Cast to OlapWrapper lets code work on JDK1.5, before java.sql.Wrapper
    //noinspection RedundantCast
    return ((OlapWrapper) jdbcConnection).unwrap(OlapConnection.class);
}
 

import mondrian.olap.DriverManager; //导入依赖的package包/类
OlapConnection getConnection(
    CatalogInfo catalogInfo,
    MondrianServer server,
    String roleName,
    Properties props)
    throws SQLException
{
  String connectString = catalogInfo.olap4jConnectString;

  // Save the server for the duration of the call to 'getConnection'.
  final LockBox.Entry entry =
      MondrianServerRegistry.INSTANCE.lockBox.register(server);

  final Properties properties = new Properties();
  properties.setProperty(
      RolapConnectionProperties.Instance.name(),
      entry.getMoniker());
  if (roleName != null) {
      properties.setProperty(
          RolapConnectionProperties.Role.name(),
          roleName);
  }
  properties.putAll(props);
  // Make sure we load the Mondrian driver into
  // the ClassLoader.
  try {
    ClassResolver.INSTANCE.forName(
        MondrianOlap4jDriver.class.getName(), true);
  } catch (ClassNotFoundException e) {
      throw new OlapException("Cannot find mondrian olap4j driver.");
  }

  final java.sql.Connection connection =
      java.sql.DriverManager.getConnection(connectString, properties);
  return ((OlapWrapper) connection).unwrap(OlapConnection.class);
}
 

import mondrian.olap.DriverManager; //导入依赖的package包/类
/**
 * Check if schema file is valid by initiating a mondrian connection.
 */
private void checkSchemaFile(File file) {
    try {
        // this connection parses the catalog file which if invalid will
        // throw exception
        PropertyList list = new PropertyList();
        list.put("Provider", "mondrian");
        list.put("Jdbc", jdbcConnectionUrl);
        list.put("Catalog", file.toURI().toURL().toString());
        list.put("JdbcDrivers", jdbcDriverClassName);
        if (jdbcUsername != null && jdbcUsername.length() > 0) {
            list.put("JdbcUser", jdbcUsername);
        }
        if (jdbcPassword != null && jdbcPassword.length() > 0) {
            list.put("JdbcPassword", jdbcPassword);
        }

        DriverManager.getConnection(list, null);
    } catch (Exception ex) {
        LOGGER.error(
            "Exception : Schema file "
            + file.getAbsolutePath()
            + " is invalid."
            + ex.getMessage(), ex);
    } catch (Error err) {
        LOGGER.error(
            "Error : Schema file "
            + file.getAbsolutePath()
            + " is invalid."
            + err.getMessage(), err);
    }
}
 

import mondrian.olap.DriverManager; //导入依赖的package包/类
public void testSchema3withVersion() {
    TestContext testContext =
        TestContext.instance().withSchema(SCHEMA_3_VHEADER + SCHEMA_3_BODY);
    Util.PropertyList connectInfo =
        testContext.getConnectionProperties();
    Connection conn = DriverManager.getConnection(connectInfo, null);
    assertNotNull(conn);
    conn.close();
}
 

import mondrian.olap.DriverManager; //导入依赖的package包/类
public void testSchema3noVersion() {
    TestContext testContext =
        TestContext.instance().withSchema(SCHEMA_3_HEADER + SCHEMA_3_BODY);
    Util.PropertyList connectInfo =
        testContext.getConnectionProperties();
    Connection conn = DriverManager.getConnection(connectInfo, null);
    assertNotNull(conn);
    conn.close();
}
 

import mondrian.olap.DriverManager; //导入依赖的package包/类
public void testSchema4withVersion() {
    TestContext testContext =
        TestContext.instance().withSchema(SCHEMA_4_HEADER + SCHEMA_4_BODY);
    Util.PropertyList connectInfo =
        testContext.getConnectionProperties();
    try {
        Connection conn = DriverManager.getConnection(connectInfo, null);
        conn.close();
        Assert.fail("No exception thrown for version 4 schema.");
    } catch (MondrianException e) {
        assertTrue(e.getMessage().contains("Schema version"));
    }
}
 

import mondrian.olap.DriverManager; //导入依赖的package包/类
public void testSchema4noVersion() {
    TestContext testContext =
        TestContext.instance().withSchema(
            SCHEMA_4_NVHEADER + SCHEMA_4_BODY);
    Util.PropertyList connectInfo =
        testContext.getConnectionProperties();
    try {
        Connection conn = DriverManager.getConnection(connectInfo, null);
        conn.close();
        Assert.fail("No exception thrown for version 4 schema.");
    } catch (MondrianException e) {
        assertTrue(e.getMessage().contains("Schema version"));
    }
}
 

import mondrian.olap.DriverManager; //导入依赖的package包/类
public void openQuery() throws KettleDatabaseException {

    	connection = null;
    	
		if (databaseMeta.getAccessType() == DatabaseMeta.TYPE_ACCESS_JNDI){
			DataSource dataSource = DataSourceProviderFactory.getDataSourceProviderInterface().getNamedDataSource(databaseMeta.getDatabaseName());
			mondrian.olap.Util.PropertyList propList = new mondrian.olap.Util.PropertyList();
			propList.put("Provider", "mondrian");
			propList.put("Catalog", space.environmentSubstitute(catalog));
			connection = DriverManager.getConnection(propList, null, dataSource);
		}
		else{

	    	String connectString = "Provider=mondrian;" +
            "Jdbc='"+space.environmentSubstitute(databaseMeta.getURL())+"';"+
    		"Catalog='"+space.environmentSubstitute(catalog)+"';"+
            "JdbcDrivers="+space.environmentSubstitute(databaseMeta.getDriverClass())+";";

	    	if (!Const.isEmpty(databaseMeta.getUsername())) {
	    		connectString+="JdbcUser="+space.environmentSubstitute(databaseMeta.getUsername())+";";
	    	}
	    	if (!Const.isEmpty(databaseMeta.getPassword())) {
	    		connectString+="JdbcPassword="+space.environmentSubstitute(databaseMeta.getPassword())+";";
	    	}
	    	connection = DriverManager.getConnection(connectString, null);
			
		}
		
        query = connection.parseQuery(queryString);
        result = connection.execute(query);
    }
 

import mondrian.olap.DriverManager; //导入依赖的package包/类
/**
 * create a new connection to Mondrian
 */
public void valueBound(HttpSessionBindingEvent ev) {
    String connectString =
        servletContext.getInitParameter("connectString");
    LOGGER.debug("connectString: " + connectString);
    this.connection =
        DriverManager.getConnection(
            connectString,
            new ServletContextCatalogLocator(servletContext));
    if (this.connection == null) {
        throw new RuntimeException(
            "No ROLAP connection from connectString: "
                + connectString);
    }
}
 

import mondrian.olap.DriverManager; //导入依赖的package包/类
Test(String[] args)
{
    pw = new PrintWriter(System.out, true);
    String connectString =
        "Data Source=LOCALHOST;Provider=msolap;Catalog=Foodmart";
    connection =
        (RolapConnection) DriverManager.getConnection(connectString, null);
}
 

import mondrian.olap.DriverManager; //导入依赖的package包/类
/**
 * Check if schema file is valid by initiating a mondrian connection.
 */
private void checkSchemaFile(File file) {
    try {
        // this connection parses the catalog file which if invalid will
        // throw exception
        PropertyList list = new PropertyList();
        list.put("Provider", "mondrian");
        list.put("Jdbc", jdbcConnectionUrl);
        list.put("Catalog", file.toURL().toString());
        list.put("JdbcDrivers", jdbcDriverClassName);
        if (jdbcUsername != null && jdbcUsername.length() > 0) {
            list.put("JdbcUser", jdbcUsername);
        }
        if (jdbcPassword != null && jdbcPassword.length() > 0) {
            list.put("JdbcPassword", jdbcPassword);
        }

        // clear cache before connecting
        AggregationManager.instance().getCacheControl(null)
            .flushSchemaCache();

        DriverManager.getConnection(list, null);
    } catch (Exception ex) {
        LOGGER.error(
            "Exception : Schema file "
            + file.getAbsolutePath()
            + " is invalid."
            + ex.getMessage(), ex);
    } catch (Error err) {
        LOGGER.error(
            "Error : Schema file "
            + file.getAbsolutePath()
            + " is invalid."
            + err.getMessage(), err);
    }
}
 

import mondrian.olap.DriverManager; //导入依赖的package包/类
/**
 * Returns a connection to the FoodMart database.
 */
public synchronized Connection getFoodMartConnection() {
    if (foodMartConnection == null) {
        foodMartConnection =
            DriverManager.getConnection(
                getFoodMartConnectionProperties(),
                null);
    }
    return foodMartConnection;
}
 

import mondrian.olap.DriverManager; //导入依赖的package包/类
public CellSet executeOlap4jXmlaQuery(String queryString)
    throws SQLException
{
    String schema = getConnectionProperties()
        .get(RolapConnectionProperties.CatalogContent.name());
    if (schema == null) {
        schema = getRawSchema();
    }
    // TODO:  Need to better handle semicolons in schema content.
    // Util.parseValue does not appear to allow escaping them.
    schema = schema.replace(""", "").replace(";", "");

    String Jdbc = getConnectionProperties()
        .get(RolapConnectionProperties.Jdbc.name());

    String cookie = XmlaOlap4jDriver.nextCookie();
    Map<String, String> catalogs = new HashMap<String, String>();
    catalogs.put("FoodMart", "");
    XmlaOlap4jDriver.PROXY_MAP.put(
        cookie, new MondrianInprocProxy(
            catalogs,
            "jdbc:mondrian:Server=http://whatever;"
            +  "Jdbc=" + Jdbc + ";TestProxyCookie="
            + cookie
            + ";CatalogContent=" + schema));
    try {
        Class.forName("org.olap4j.driver.xmla.XmlaOlap4jDriver");
    } catch (ClassNotFoundException e) {
        throw new RuntimeException("oops", e);
    }
    Properties info = new Properties();
    info.setProperty(
        XmlaOlap4jDriver.Property.CATALOG.name(), "FoodMart");
    java.sql.Connection connection = java.sql.DriverManager.getConnection(
        "jdbc:xmla:Server=http://whatever;Catalog=FoodMart;TestProxyCookie="
            + cookie,
        info);
    OlapConnection olapConnection =
        connection.unwrap(OlapConnection.class);
    OlapStatement statement = olapConnection.createStatement();
    return  statement.executeOlapQuery(queryString);
}
 

import mondrian.olap.DriverManager; //导入依赖的package包/类
public mondrian.olap.Connection getMondrianConnection() throws Exception {
    
    if (mondrianConnection == null)
    {
        JDBCConnection con = getJDBCConnection();

        // Force opening connection...
        ClassLoader originalCL = Thread.currentThread().getContextClassLoader();

        
        try {

           Connection conn = null;
        try {
                conn = con.getConnection();
                if (conn == null) throw new Exception("No DB connection");
        } finally {
            // Clean up
            if( conn!=null ) try{ conn.close(); } catch(Exception e) { /* anyone really care? */ }
        }


        Thread.currentThread().setContextClassLoader( IReportManager.getReportClassLoader());
        Util.PropertyList props = new Util.PropertyList();
        props.put("Catalog", getCatalogUri());
        props.put("Provider", "mondrian");
        props.put("Locale", Locale.getDefault().getLanguage());

        SimpleSQLDataSource ds = new SimpleSQLDataSource(con);

        mondrianConnection = DriverManager.getConnection(props, null, ds);
        /*
        mondrianConnection  = DriverManager.getConnection(
	"Provider=mondrian;" + 
	"JdbcDrivers=" + escapeProperty( con.getJDBCDriver() )  + ";" +
	"Jdbc=" + escapeProperty( con.getUrl() ) + ";" +
	"JdbcUser=" + escapeProperty( con.getUsername() ) + ";" +
	"JdbcPassword=" + escapeProperty( con.getPassword() ) + ";" +
	"Catalog=" + escapeProperty( getCatalogUri() ) + ";",
	null, false);
        */
        
        } catch (Exception ex) {
            ex.printStackTrace();
            throw ex;
        }

        Thread.currentThread().setContextClassLoader( originalCL);

    }
    usedby++;
    return mondrianConnection;
}