import org.apache.commons.dbcp2.BasicDataSource;
public class MySqlConnectionPool {
private static BasicDataSource dataSource;
static {
dataSource = new BasicDataSource();
dataSource.setDriverClassName("com.teradata.jdbc.TeraDriver");
dataSource.setUrl("jdbc:teradata://localhost/DATABASE=mydb");
dataSource.setUsername("username");
dataSource.setPassword("password");
}
public static Connection getConnection() throws SQLException {
return dataSource.getConnection();
}
}
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class TeradataConnectionExample {
public static void main(String[] args) {
try {
Class.forName("com.teradata.jdbc.TeraDriver");
Connection connection = DriverManager.getConnection("jdbc:teradata://localhost/DATABASE=mydb;COMPRESS=YES", "username", "password");
// ...
connection.close();
e.printStackTrace();
}
}
}
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
public class TeradataQueryExample {
public static void main(String[] args) {
try {
Connection connection = MySqlConnectionPool.getConnection();
String sql = "SELECT * FROM mytable WHERE column = ?";
PreparedStatement statement = connection.prepareStatement(sql);
statement.setString(1, "value");
ResultSet resultSet = statement.executeQuery();
while (resultSet.next()) {
// ...
}
resultSet.close();
statement.close();
connection.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
public class TeradataBatchExample {
public static void main(String[] args) {
try {
Connection connection = MySqlConnectionPool.getConnection();
connection.setAutoCommit(false);
String sql = "INSERT INTO mytable (column1, column2) VALUES (?, ?)";
PreparedStatement statement = connection.prepareStatement(sql);
for (int i = 0; i < 1000; i++) {
statement.setString(1, "value1");
statement.setString(2, "value2");
statement.addBatch();
}
statement.executeBatch();
connection.commit();
statement.close();
connection.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
