com.mysql.jdbc.jdbc2.optional.MysqlDataSource.getConnection()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(8.2k)|赞(0)|评价(0)|浏览(153)

本文整理了Java中com.mysql.jdbc.jdbc2.optional.MysqlDataSource.getConnection()方法的一些代码示例,展示了MysqlDataSource.getConnection()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。MysqlDataSource.getConnection()方法的具体详情如下:
包路径:com.mysql.jdbc.jdbc2.optional.MysqlDataSource
类名称:MysqlDataSource
方法名:getConnection

MysqlDataSource.getConnection介绍

暂无

代码示例

代码示例来源:origin: alibaba/nacos

dataSource.setPort(ip.getPort());
connection = dataSource.getConnection();
CONNECTION_POOL.put(key, connection);

代码示例来源:origin: stackoverflow.com

import com.mysql.jdbc.jdbc2.optional.MysqlDataSource;
//...
MysqlDataSource mysql = (MysqlDataSource) context.lookup("jdbc/MySQLDataSource");
mysql.setRewriteBatchedStatements(true);
Connection conn = mysql.getConnection();

代码示例来源:origin: games647/LagMonitor

public void saveTps(float tps) {
    try (Connection con = dataSource.getConnection();
       PreparedStatement stmt = con.prepareStatement("INSERT INTO " + prefix
           + TPS_TABLE + " (tps) VALUES (?)")) {
      stmt.setFloat(1, tps);
      stmt.execute();
    } catch (SQLException sqlEx) {
      logger.log(Level.SEVERE, "Error saving tps to database", sqlEx);
      logger.log(Level.SEVERE, "Using this data {0}", new Object[]{tps});
    }
  }
}

代码示例来源:origin: stackoverflow.com

public static void main(String[] args) throws Exception {
  MysqlDataSource db = new MysqlDataSource();
  db.setDatabaseName("test");
  Connection conn = db.getConnection("test", "test");

  ResultSet res = conn.prepareStatement("SELECT * FROM thing").executeQuery();
  res.next();
  System.out.println("Get a int as a string: " + res.getString("a_int"));

}

代码示例来源:origin: com.carrotsearch/junit-benchmarks

@Override
protected Connection createConnection() throws SQLException
{
  final MysqlDataSource ds = new MysqlDataSource();
  ds.setURL(dbUrl);
  Connection results = ds.getConnection();
  results.setAutoCommit(false);
  return results;
}

代码示例来源:origin: org.scijava/junit-benchmarks

@Override
protected Connection createConnection() throws SQLException
{
  final MysqlDataSource ds = new MysqlDataSource();
  ds.setURL(dbUrl);
  Connection results = ds.getConnection();
  results.setAutoCommit(false);
  return results;
}

代码示例来源:origin: games647/LagMonitor

public void savePlayers(Collection<PlayerData> playerData) {
  if (playerData.isEmpty()) {
    return;
  }
  try (Connection con = dataSource.getConnection();
     PreparedStatement stmt = con.prepareStatement("INSERT INTO " + prefix + PLAYERS_TABLE
         + " (world_id, uuid, name, ping) "
         + "VALUES (?, ?, ?, ?)")) {
    for (PlayerData data : playerData) {
      stmt.setInt(1, data.getWorldId());
      stmt.setString(2, data.getUuid().toString());
      stmt.setString(3, data.getPlayerName());
      stmt.setInt(4, data.getPing());
      stmt.addBatch();
    }
    stmt.executeBatch();
  } catch (SQLException sqlEx) {
    logger.log(Level.SEVERE, "Error saving player data to database", sqlEx);
    logger.log(Level.SEVERE, "Using this data {0}", playerData);
  }
}

代码示例来源:origin: stackoverflow.com

MysqlDataSource dataSource = new MysqlDataSource();
dataSource.setUser("scott");
dataSource.setPassword("tiger");
dataSource.setServerName("myDatabaseHost.example.org");
and then obtain connections from it, same as above:

Connection conn = dataSource.getConnection();
Statement stmt = conn.createStatement();
ResultSet rs = stmt.executeQuery("SELECT ID FROM USERS");
...
rs.close();
stmt.close();
conn.close();

代码示例来源:origin: stackoverflow.com

MysqlDataSource dataSource = new MysqlDataSource();
dataSource.setUser(user);
dataSource.setPassword(password);
dataSource.setServerName(server);
dataSource.setDatabaseName(database);
Connection conn = dataSource.getConnection();

PreparedStatement stmt = conn.prepareStatement("INSERT INTO table (name, grade, age) VALUES (?, ?, ?)");

...then while going throug the XML:

stmt.setString(1, name);
stmt.setString(2, grade);
stmt.setString(3, age);
stmt.execute();

...at the end:
stmt.close();
conn.commit();
conn.close()

代码示例来源:origin: boonproject/boon

protected void connect() {
  try {
    MysqlDataSource dataSource = new MysqlDataSource();
    dataSource.setURL(url);
    dataSource.setPassword(password);
    dataSource.setUser(userName);
    connection = dataSource.getConnection();
    connection.setAutoCommit(true);
    closed = false;
    totalConnectionOpen++;
  } catch (SQLException sqlException) {
    this.closed = true;
    connection = null;
    handle("Unable to connect", sqlException);
  }
}

代码示例来源:origin: boonproject/boon

protected void connect() {
  try {
    MysqlDataSource dataSource = new MysqlDataSource();
    dataSource.setURL(url);
    dataSource.setPassword(password);
    dataSource.setUser(userName);
    connection = dataSource.getConnection();
    connection.setAutoCommit(true);
    closed = false;
    totalConnectionOpen++;
  } catch (SQLException sqlException) {
    this.closed = true;
    connection = null;
    handle("Unable to connect", sqlException);
  }
}

代码示例来源:origin: io.fastjson/slumberdb-mysql

protected void connect() {
  try {
    MysqlDataSource dataSource = new MysqlDataSource();
    dataSource.setURL(url);
    dataSource.setPassword(password);
    dataSource.setUser(userName);
    connection = dataSource.getConnection();
    connection.setAutoCommit(true);
    closed = false;
    totalConnectionOpen++;
  } catch (SQLException sqlException) {
    this.closed = true;
    connection = null;
    handle("Unable to connect", sqlException);
  }
}

代码示例来源:origin: boonproject/boon

/**
 * Connects to the DB and tracks if successful so upstream stuff can try to reconnect.
 */
protected void connect() {
  try {
    MysqlDataSource dataSource = new MysqlDataSource();
    dataSource.setURL(url);
    dataSource.setPassword(password);
    dataSource.setUser(userName);
    connection = dataSource.getConnection();
    connection.setAutoCommit(true);
    closed = false;
    totalConnectionOpen++;
  } catch (SQLException sqlException) {
    this.closed = true;
    connection = null;
    handle("Unable to connect", sqlException);
  }
}

代码示例来源:origin: boonproject/boon

/**
 * Connects to the DB and tracks if successful so upstream stuff can try to reconnect.
 */
protected void connect() {
  try {
    MysqlDataSource dataSource = new MysqlDataSource();
    dataSource.setURL(url);
    dataSource.setPassword(password);
    dataSource.setUser(userName);
    connection = dataSource.getConnection();
    connection.setAutoCommit(true);
    closed = false;
    totalConnectionOpen++;
  } catch (SQLException sqlException) {
    this.closed = true;
    connection = null;
    handle("Unable to connect", sqlException);
  }
}

代码示例来源:origin: io.fastjson/slumberdb-mysql

/**
 * Connects to the DB and tracks if successful so upstream stuff can try to reconnect.
 */
protected void connect() {
  try {
    MysqlDataSource dataSource = new MysqlDataSource();
    dataSource.setURL(url);
    dataSource.setPassword(password);
    dataSource.setUser(userName);
    connection = dataSource.getConnection();
    connection.setAutoCommit(true);
    closed = false;
    totalConnectionOpen++;
  } catch (SQLException sqlException) {
    this.closed = true;
    connection = null;
    handle("Unable to connect", sqlException);
  }
}

代码示例来源:origin: stackoverflow.com

MysqlDataSource ds = new MysqlDataSource();
ds.setServerName(serverName);
ds.setDatabaseName(mydatabase);
ds.setUser(username);
ds.setPassword(password);
connection = ds.getConnection();

代码示例来源:origin: stackoverflow.com

MysqlDataSource ds = new MysqlDataSource();
ds.setDatabaseName("DATABASE");
ds.setUser("USERNAME");
ds.setPassword("USER PASSWORD");
ds.setServerName("localhost");
ds.setPort(3306);
connection = ds.getConnection();

代码示例来源:origin: stackoverflow.com

MysqlDataSource dataSource = new MysqlDataSource();
dataSource.setServerName("localhost");
dataSource.setDatabaseName("inventry");
dataSource.setPortNumber(3306);
dataSource.setUser("root");
dataSource.setPassword(""); // blank password is a terrible idea

Connection connection = dataSource.getConnection();

代码示例来源:origin: stackoverflow.com

MysqlDataSource ds = new MysqlDataSource();
ds.setServerName("localhost");
ds.setPort("3306");
ds.setDatabaseName("testdb");
ds.setUser("root");
ds.setPassword("");
Connection connection = ds.getConnection();

代码示例来源:origin: stackoverflow.com

public class MySqlConnect {

  public static Connection connectToDB() {
    try {
      MysqlDataSource dataSource = new MysqlDataSource();
      dataSource.setServerName("localhost");
      dataSource.setDatabaseName("auto_lube");
      dataSource.setPortNumber(3306);
      dataSource.setUser("root");
      dataSource.setPassword("mehar");

      Connection conn = dataSource.getConnection();
      JOptionPane.showMessageDialog(null, "Connection established"); // better log this message
      return conn;

    } catch (Exception e) {
      JOptionPane.showMessageDialog(null, e); // better log the exception
      return null;
    }
  }
}

相关文章