Examples of com.mysql.jdbc.jdbc2.optional.MysqlXADataSource

com.mysql.jdbc.jdbc2.optional.MysqlDataSource
@author mmatthewTo change this generated comment edit the template variable "typecomment": Window>Preferences>Java>Templates. To enable and disable the creation of type comments go to Window>Preferences>Java>Code Generation.

    String serverName = System.getProperty(DS_HOST_PROP_NAME);


    // Only run this test if at least one of the above are set
    if ((databaseName != null) || (serverName != null)
        || (userName != null) || (password != null) || (port != null)) {
      MysqlConnectionPoolDataSource ds = new MysqlConnectionPoolDataSource();


      if (databaseName != null) {
        ds.setDatabaseName(databaseName);
      }


      if (userName != null) {
        ds.setUser(userName);
      }


      if (password != null) {
        ds.setPassword(password);
      }


      if (port != null) {
        ds.setPortNumber(Integer.parseInt(port));
      }


      if (serverName != null) {
        ds.setServerName(serverName);
      }


      bindDataSource(jndiName, ds);


      ConnectionPoolDataSource boundDs = null;

View Full Code Here

    this.tempDir = File.createTempFile("jnditest", null);
    this.tempDir.delete();
    this.tempDir.mkdir();
    this.tempDir.deleteOnExit();


    MysqlConnectionPoolDataSource ds;
    Hashtable env = new Hashtable();
    env.put(Context.INITIAL_CONTEXT_FACTORY,
        "com.sun.jndi.fscontext.RefFSContextFactory");
    this.ctx = new InitialContext(env);
    assertTrue("Naming Context not created", this.ctx != null);
    ds = new MysqlConnectionPoolDataSource();
    ds.setUrl(dbUrl); // from BaseTestCase
    ds.setDatabaseName("test");
    this.ctx.bind(this.tempDir.getAbsolutePath() + "/test", ds);
  }

View Full Code Here


    return boundDs;
  }


  public void testCSC4616() throws Exception {
    MysqlConnectionPoolDataSource ds = new MysqlConnectionPoolDataSource();
    ds.setURL(BaseTestCase.dbUrl);
    PooledConnection pooledConn = ds.getPooledConnection();
    Connection physConn = pooledConn.getConnection();
    Statement physStatement = physConn.createStatement();


    Method enableStreamingResultsMethodStmt = Class.forName(
        "com.mysql.jdbc.jdbc2.optional.StatementWrapper").getMethod(

View Full Code Here

     * a prepared statement.
     * 
   * @throws Exception
   */
  public void testBug32101() throws Exception {
    MysqlConnectionPoolDataSource ds = new MysqlConnectionPoolDataSource();
    ds.setURL(BaseTestCase.dbUrl);
    PooledConnection pc = ds.getPooledConnection();
    assertNotNull(pc.getConnection().prepareStatement("SELECT 1"));
    assertNotNull(pc.getConnection().prepareStatement("SELECT 1", Statement.RETURN_GENERATED_KEYS));
    assertNotNull(pc.getConnection().prepareStatement("SELECT 1", new int[0]));
    assertNotNull(pc.getConnection().prepareStatement("SELECT 1", new String[0]));
    assertNotNull(pc.getConnection().prepareStatement("SELECT 1", ResultSet.TYPE_FORWARD_ONLY, ResultSet.CONCUR_READ_ONLY));

View Full Code Here

  }


  public void testBug35810() throws Exception {
    int defaultConnectTimeout = ((ConnectionProperties) this.conn).getConnectTimeout();
    int nonDefaultConnectTimeout = defaultConnectTimeout + 1000 * 2;
    MysqlConnectionPoolDataSource cpds = new MysqlConnectionPoolDataSource();
    String dsUrl = BaseTestCase.dbUrl;
    if (dsUrl.indexOf("?") == -1) {
      dsUrl += "?";
    } else {
      dsUrl += "&";
    }
    
    dsUrl += "connectTimeout=" + nonDefaultConnectTimeout;
    cpds.setUrl(dsUrl);
    
    Connection dsConn = cpds.getPooledConnection().getConnection();
    int configuredConnectTimeout = ((ConnectionProperties) dsConn).getConnectTimeout();
    
    assertEquals("Connect timeout spec'd by URL didn't take", nonDefaultConnectTimeout, configuredConnectTimeout);
    assertFalse("Connect timeout spec'd by URL didn't take", defaultConnectTimeout == configuredConnectTimeout);
  }

View Full Code Here

  public static final int MYSQL_PORT = 3306;


  @Bean
  @Override
  public DataSource dataSource() {
    MysqlConnectionPoolDataSource ds = new MysqlConnectionPoolDataSource();
    ds.setUser("root");
    ds.setPassword(System.getProperty("mysql.password", ""));
    ds.setDatabaseName("spring_data_jdbc_repository_test");
    return ds;
  }

View Full Code Here

    }


    String newUrl = String.format("jdbc:mysql:loadbalance://%s,%s/%s?%s",
        hostSpec, hostSpec, database, configs.toString());


    MysqlConnectionPoolDataSource ds = new MysqlConnectionPoolDataSource();
    ds.setUrl(newUrl);


    Connection c = ds.getPooledConnection().getConnection();
    c.createStatement().executeQuery("SELECT 1");
    c.prepareStatement("SELECT 1").executeQuery();
  }

View Full Code Here

    }


    String newUrl = String.format("jdbc:mysql:loadbalance://%s,%s/%s?%s",
        hostSpec, hostSpec, database, configs.toString());


    MysqlConnectionPoolDataSource ds = new MysqlConnectionPoolDataSource();
    ds.setUrl(newUrl);


    Connection c = ds.getPooledConnection().getConnection();
    c.createStatement().executeQuery("SELECT 1");
    c.prepareStatement("SELECT 1").executeQuery();
  }

View Full Code Here

                    serviceReg.unregister();
                } catch (Exception e) {
                }
                serviceReg = null;
            }
            MysqlDataSource ds = new MysqlDataSource();
            ds.setUrl(getString("url", properties));
            ds.setUser(getString("user", properties));
            ds.setPassword(getString("password", properties));


            Dictionary<String, String> regProperties = new Hashtable<String, String>();
            regProperties.put("osgi.jndi.service.name" , getString("name", properties));
            serviceReg = context.registerService(DataSource.class, ds, regProperties);
        }

View Full Code Here

    String user = "root";
    String password = "";


    public Connection getConnection() {
        if (connection == null) {
            MysqlDataSource dataSource = new MysqlDataSource();
            dataSource.setUrl(url);
            dataSource.setUser(user);
            dataSource.setPassword(password);
            try {
                connection = dataSource.getConnection();
            } catch (SQLException e) {
                System.out.println("Koneksi mysql gagal! \n Error: " + e.getMessage());
            }
        }
        return connection;

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

Related Classes of com.mysql.jdbc.jdbc2.optional.MysqlXADataSource

bean.DbUtility

bean.DbUtilitySMS

cn.iver.common.Config

com.alibaba.druid.util.MySqlUtils

com.carrotsearch.junitbenchmarks.mysql.MySQLConsumer

com.mysql.jdbc.jdbc2.optional.JDBC4PreparedStatementWrapper

com.mysql.jdbc.jdbc2.optional.MysqlPooledConnection

com.nurkiewicz.jdbcrepository.mysql.JdbcRepositoryTestMysqlConfig

com.proofpoint.dbpool.MySqlDataSource

com.taobao.metamorphosis.example.XATransactionProducer

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.