<dependency>
<groupId>com.amazonaws</groupId>
<artifactId>aws-java-sdk</artifactId>
<version>1.11.534</version>
</dependency>
<dependency>
<groupId>com.amazon.redshift</groupId>
<artifactId>redshift-jdbc42</artifactId>
<version>1.2.43.1067</version>
</dependency>
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class PostgreSqlConnection {
public static Connection connect() throws SQLException {
String url = "jdbc:postgresql://host:port/database";
String user = "your_username";
String password = "your_password";
Connection conn = DriverManager.getConnection(url, user, password);
return conn;
}
}
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
public class DataMigration {
public static void main(String[] args) throws SQLException {
Connection sourceConn = PostgreSqlConnection.connect();
Connection targetConn = PostgreSqlConnection.connect();
String selectQuery = "SELECT * FROM source_table";
String insertQuery = "INSERT INTO target_table (column1, column2, column3) VALUES (?, ?, ?)";
PreparedStatement selectStatement = sourceConn.prepareStatement(selectQuery);
ResultSet resultSet = selectStatement.executeQuery();
PreparedStatement insertStatement = targetConn.prepareStatement(insertQuery);
while (resultSet.next()) {
insertStatement.setString(1, resultSet.getString("column1"));
insertStatement.setInt(2, resultSet.getInt("column2"));
insertStatement.setString(3, resultSet.getString("column3"));
insertStatement.executeUpdate();
}
System.out.println("Data migration completed!");
selectStatement.close();
insertStatement.close();
resultSet.close();
sourceConn.close();
targetConn.close();
}
}
