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

com.mysql.jdbc.jdbc2.optional.MysqlXADataSource
This class is used to obtain a physical connection and instantiate and return a MysqlPooledConnection. J2EE application servers map client calls to dataSource.getConnection to this class based upon mapping set within deployment descriptor. This class extends MysqlDataSource. @see javax.sql.PooledConnection @see javax.sql.ConnectionPoolDataSource @see org.gjt.mm.mysql.MysqlDataSource @author Todd Wolff

    m_body = body;
  }
  
  public static LinkedList<ArtifactMessage> getArtifactMessages(long artifact_id, Date begin, Date end)
  {
    MysqlDataSource l_ds = DBAccess.ReturnDataSource();
      Connection l_con = null;
      Statement l_stat = null;
      LinkedList<ArtifactMessage> l_artifacts = new LinkedList<ArtifactMessage>();
      
      try
      {
        l_con = l_ds.getConnection();
      l_stat = l_con.createStatement();  


        
      ResultSet s = l_stat.executeQuery("select id, artifact_id, submitted_by, from_unixtime(adddate) as adddate, body from artifact_message where artifact_id = " + artifact_id 
          + " and from_unixtime(adddate) > '"+ df.format(begin) + "' and from_unixtime(adddate) < '" + df.format(end) + "'");

View Full Code Here

    m_submitted_by = submitted_by;
    m_adddate = adddate;
  }
  public static LinkedList<ArtifactMessage> getArtifactMessages(long artifact_id)
  {
    MysqlDataSource l_ds = DBAccess.ReturnDataSource();
      Connection l_con = null;
      Statement l_stat = null;
      LinkedList<ArtifactMessage> l_artifact_ids = new LinkedList<ArtifactMessage>();
      
      try
      {
        l_con = l_ds.getConnection();
      l_stat = l_con.createStatement();  


        
      ResultSet s = l_stat.executeQuery("select id, artifact_id, submitted_by, from_unixtime(adddate) as adddate, body from artifact_message where artifact_id = " + artifact_id);

View Full Code Here

   * due to Reference containing RefAddrs with null content.
   * 
   * @throws Exception if the test fails
   */
  public void testBug16791() throws Exception {
    MysqlDataSource myDs = new MysqlDataSource();
    myDs.setUrl(dbUrl);
    Reference asRef = myDs.getReference();
    System.out.println(asRef);
    
    removeFromRef(asRef, "port");
    removeFromRef(asRef, NonRegisteringDriver.USER_PROPERTY_KEY);
    removeFromRef(asRef, NonRegisteringDriver.PASSWORD_PROPERTY_KEY);

View Full Code Here

    assertEquals("Connect timeout spec'd by URL didn't take", nonDefaultConnectTimeout, configuredConnectTimeout);
    assertFalse("Connect timeout spec'd by URL didn't take", defaultConnectTimeout == configuredConnectTimeout);
  }


  public void testBug42267() throws Exception {
    MysqlDataSource ds = new MysqlDataSource();
    ds.setUrl(dbUrl);
    Connection conn = ds.getConnection();
    String query = "select 1,2,345";
    PreparedStatement ps = conn.prepareStatement(query);
    String psString = ps.toString();
    assertTrue("String representation of wrapped ps should contain query string", psString.endsWith(": " + query));
    ps.close();

View Full Code Here

   * expect them to be.
   * 
   * @throws Exception if the test fails.
   */
  public void testBug19169() throws Exception {
    MysqlDataSource toSerialize = new MysqlDataSource();
    toSerialize.setZeroDateTimeBehavior("convertToNull");
    
    boolean testBooleanFlag = !toSerialize.getAllowLoadLocalInfile();
    toSerialize.setAllowLoadLocalInfile(testBooleanFlag);
    
    int testIntFlag = toSerialize.getBlobSendChunkSize() + 1;
    toSerialize.setBlobSendChunkSize(String.valueOf(testIntFlag));
    
    ByteArrayOutputStream bOut = new ByteArrayOutputStream();
    ObjectOutputStream objOut = new ObjectOutputStream(bOut);
    objOut.writeObject(toSerialize);
    objOut.flush();
    
    ObjectInputStream objIn = new ObjectInputStream(new ByteArrayInputStream(bOut.toByteArray()));
    
    MysqlDataSource thawedDs = (MysqlDataSource)objIn.readObject();
    
    assertEquals("convertToNull", thawedDs.getZeroDateTimeBehavior());
    assertEquals(testBooleanFlag, thawedDs.getAllowLoadLocalInfile());
    assertEquals(testIntFlag, thawedDs.getBlobSendChunkSize());
  }

View Full Code Here

   * due to Reference containing RefAddrs with null content.
   * 
   * @throws Exception if the test fails
   */
  public void testBug16791() throws Exception {
    MysqlDataSource myDs = new MysqlDataSource();
    myDs.setUrl(dbUrl);
    Reference asRef = myDs.getReference();
    System.out.println(asRef);
    
    removeFromRef(asRef, "port");
    removeFromRef(asRef, NonRegisteringDriver.USER_PROPERTY_KEY);
    removeFromRef(asRef, NonRegisteringDriver.PASSWORD_PROPERTY_KEY);
    removeFromRef(asRef, "serverName");
    removeFromRef(asRef, "databaseName");
    
    MysqlDataSource newDs = (MysqlDataSource)new MysqlDataSourceFactory().getObjectInstance(asRef, null, null, null);
  }

View Full Code Here

    removeFromRef(asRef, NonRegisteringDriver.PASSWORD_PROPERTY_KEY);
    removeFromRef(asRef, "serverName");
    removeFromRef(asRef, "databaseName");
    
    //MysqlDataSource newDs = (MysqlDataSource)
    new MysqlDataSourceFactory().getObjectInstance(asRef, null, null, null);
  }

View Full Code Here

    removeFromRef(asRef, NonRegisteringDriver.USER_PROPERTY_KEY);
    removeFromRef(asRef, NonRegisteringDriver.PASSWORD_PROPERTY_KEY);
    removeFromRef(asRef, "serverName");
    removeFromRef(asRef, "databaseName");
    
    MysqlDataSource newDs = (MysqlDataSource)new MysqlDataSourceFactory().getObjectInstance(asRef, null, null, null);
  }

View Full Code Here

    if (this.pooledConnection == null) {
      // no-op
      return;
    }
    
    MysqlPooledConnection con = this.pooledConnection; // we need this
                               // later...


    try {
      super.close();
    } finally {

View Full Code Here

   * 
   * @throws Exception if the test fails.
   */
  public void testXADataSource() throws Exception {
  
    MysqlXADataSource ds = new MysqlXADataSource();
    ds.setUrl(dbUrl);
    
    String name = "XA";
    this.ctx.rebind(name, ds);


    Object result = this.ctx.lookup(name);

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

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

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.