empire-db-examples/empire-db-example-jsf2/src/main/java/org/apache/empire/jsf2/websample/db/SampleDB.java [158:266]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public static class TPayments extends SampleTable { public final DBTableColumn EMPLOYEE_ID; public final DBTableColumn YEAR; public final DBTableColumn MONTH; public final DBTableColumn AMOUNT; public TPayments(SampleDB db) { super("PAYMENTS", db); // ID EMPLOYEE_ID = addForeignKey("EMPLOYEE_ID", db.EMPLOYEES, true); YEAR = addColumn("YEAR", DataType.DECIMAL, 4.0, true); MONTH = addColumn("MONTH", DataType.DECIMAL, 2.0, true); AMOUNT = addColumn("AMOUNT", DataType.DECIMAL, 8.2, true); // Primary Key setPrimaryKey(EMPLOYEE_ID, YEAR, MONTH); // optional: set entity name for selectQualified() to singular since table is plural setEntityName("PAYMENT"); } } // Declare all Tables and Views here public final TDepartments DEPARTMENTS = new TDepartments(this); public final TEmployees EMPLOYEES = new TEmployees(this); public final TPayments PAYMENTS = new TPayments(this); /** * Constructor of the SampleDB data model * * Put all foreign key relations here. */ public SampleDB() { // Define additional Foreign-Key Relations here // which have not already been defined by addForeignKey() // addRelation( {Source Column}.referenceOn( {Target Column} )); log.info("SampleDB has been created with {} Tables and {} Relations", getTables().size(), getRelations().size()); } // Needed for the DBELResolver @Override protected void register(String id) { super.register("db"); } @Override public void open(DBContext context) { // Enable prepared statements // setPreparedStatementsEnabled(true); // Check exists if (checkExists(context)) { // attach to driver super.open(context); // yes, it exists, then check the model checkDataModel(context); } else { // PostgreSQL does not support DDL in transaction if(getDbms() instanceof DBMSHandlerPostgreSQL) setAutoCommit(context, true); // create the database createDatabase(context); // PostgreSQL does not support DDL in transaction if(getDbms() instanceof DBMSHandlerPostgreSQL) setAutoCommit(context, false); // attach to driver super.open(context); } } private void createDatabase(DBContext context) { // create DDL for Database Definition DBSQLScript script = new DBSQLScript(context); getCreateDDLScript(script); // Show DDL Statement log.info(script.toString()); // Execute Script script.executeAll(false); // Commit context.commit(); } private void checkDataModel(DBContext context) { try { DBModelChecker modelChecker = context.getDbms().createModelChecker(this); // Check data model log.info("Checking DataModel for {} using {}", getClass().getSimpleName(), modelChecker.getClass().getSimpleName()); // dbo schema DBModelErrorLogger logger = new DBModelErrorLogger(); modelChecker.checkModel(this, context.getConnection(), logger); // show result log.info("Data model check done. Found {} errors and {} warnings.", logger.getErrorCount(), logger.getWarnCount()); } catch(Exception e) { log.error("FATAL error when checking data model. Probably not properly implemented by DBMSHandler!"); } } private void setAutoCommit(DBContext context, boolean enable) { try { context.getConnection().setAutoCommit(enable); } catch (SQLException e) { log.error("Unable to set AutoCommit on Connection", e); - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - empire-db-examples/empire-db-example-vue/src/main/java/org/apache/empire/vue/sample/db/SampleDB.java [168:276]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public static class TPayments extends SampleTable { public final DBTableColumn EMPLOYEE_ID; public final DBTableColumn YEAR; public final DBTableColumn MONTH; public final DBTableColumn AMOUNT; public TPayments(SampleDB db) { super("PAYMENTS", db); // ID EMPLOYEE_ID = addForeignKey("EMPLOYEE_ID", db.EMPLOYEES, true); YEAR = addColumn("YEAR", DataType.DECIMAL, 4.0, true); MONTH = addColumn("MONTH", DataType.DECIMAL, 2.0, true); AMOUNT = addColumn("AMOUNT", DataType.DECIMAL, 8.2, true); // Primary Key setPrimaryKey(EMPLOYEE_ID, YEAR, MONTH); // optional: set entity name for selectQualified() to singular since table is plural setEntityName("PAYMENT"); } } // Declare all Tables and Views here public final TDepartments DEPARTMENTS = new TDepartments(this); public final TEmployees EMPLOYEES = new TEmployees(this); public final TPayments PAYMENTS = new TPayments(this); /** * Constructor of the SampleDB data model * * Put all foreign key relations here. */ public SampleDB() { // Define additional Foreign-Key Relations here // which have not already been defined by addForeignKey() // addRelation( {Source Column}.referenceOn( {Target Column} )); log.info("SampleDB has been created with {} Tables and {} Relations", getTables().size(), getRelations().size()); } // Needed for the DBELResolver @Override protected void register(String id) { super.register("db"); } @Override public void open(DBContext context) { // Enable prepared statements // setPreparedStatementsEnabled(true); // Check exists if (checkExists(context)) { // attach to driver super.open(context); // yes, it exists, then check the model checkDataModel(context); } else { // PostgreSQL does not support DDL in transaction if(getDbms() instanceof DBMSHandlerPostgreSQL) setAutoCommit(context, true); // create the database createDatabase(context); // PostgreSQL does not support DDL in transaction if(getDbms() instanceof DBMSHandlerPostgreSQL) setAutoCommit(context, false); // attach to driver super.open(context); } } private void createDatabase(DBContext context) { // create DDL for Database Definition DBSQLScript script = new DBSQLScript(context); getCreateDDLScript(script); // Show DDL Statement log.info(script.toString()); // Execute Script script.executeAll(false); // Commit context.commit(); } private void checkDataModel(DBContext context) { try { DBModelChecker modelChecker = context.getDbms().createModelChecker(this); // Check data model log.info("Checking DataModel for {} using {}", getClass().getSimpleName(), modelChecker.getClass().getSimpleName()); // dbo schema DBModelErrorLogger logger = new DBModelErrorLogger(); modelChecker.checkModel(this, context.getConnection(), logger); // show result log.info("Data model check done. Found {} errors and {} warnings.", logger.getErrorCount(), logger.getWarnCount()); } catch(Exception e) { log.error("FATAL error when checking data model. Probably not properly implemented by DBMSHandler!"); } } private void setAutoCommit(DBContext context, boolean enable) { try { context.getConnection().setAutoCommit(enable); } catch (SQLException e) { log.error("Unable to set AutoCommit on Connection", e); - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -