We create new databases dynamically:
session.doWork(new Work() {
@Override
public void execute(Connection connection) throws SQLException {
boolean autoCommit = connection.getAutoCommit();
connection.setAutoCommit(true);
Statement stmt = connection.createStatement();
stmt.executeUpdate("CREATE DATABASE " + dbName + " WITH TEMPLATE my_template ENCODING 'UTF8'");
// set this back to previous value before returning connection to the pool
connection.setAutoCommit(autoCommit);
}
});
It uses schema template where we have all the tables definitions.
Then we build configuration and session factory:
public static Configuration buildConfiguration(String serverName, String databaseName) {
return createConfiguration()
.setProperty("connection.url", "jdbc:postgresql://" + serverName + ":5432/" + databaseName)
}
private static Configuration createConfiguration() {
Configuration configuration = new Configuration().configure(HIBERNATE_CFG_XML_FILE);
return configuration;
}
configuration.buildSessionFactory();
hibernate xml file:
<hibernate-configuration>
<session-factory>
<mapping class="com.crowdoptic.database.clustersdata.DeviceData"/>
</session-factory>
where DeviceData is regular hibernate bean:
@Entity
@Table(name="device_data")
public class DeviceData {