本文整理了Java中com.mysql.jdbc.jdbc2.optional.MysqlDataSource.getConnection()
方法的一些代码示例,展示了MysqlDataSource.getConnection()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。MysqlDataSource.getConnection()
方法的具体详情如下:
包路径:com.mysql.jdbc.jdbc2.optional.MysqlDataSource
类名称: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;
}
}
}
内容来源于网络,如有侵权,请联系作者删除!