remove erroneous comments
This commit is contained in:
parent
c0413f7deb
commit
7beee9786b
@ -7,37 +7,16 @@ import de.hsadmin.core.qserv.EntityProcessorFactory;
|
|||||||
import de.hsadmin.core.qserv.JDBCProcessor;
|
import de.hsadmin.core.qserv.JDBCProcessor;
|
||||||
import de.hsadmin.core.qserv.Processor;
|
import de.hsadmin.core.qserv.Processor;
|
||||||
|
|
||||||
/**
|
|
||||||
* Factory class which creates Processor instances for dealing with UNIX user
|
|
||||||
* accounts.
|
|
||||||
*
|
|
||||||
* @author mi
|
|
||||||
*/
|
|
||||||
public class PgSqlDatabaseProcessorFactory implements EntityProcessorFactory {
|
public class PgSqlDatabaseProcessorFactory implements EntityProcessorFactory {
|
||||||
|
|
||||||
/**
|
|
||||||
* creates a JDBCProcessor for PostgreSQL and the given user
|
|
||||||
*
|
|
||||||
* @param user
|
|
||||||
* @param password
|
|
||||||
* @return
|
|
||||||
*/
|
|
||||||
public static JDBCProcessor createPostgreSqlProcessor(String user, String password) {
|
public static JDBCProcessor createPostgreSqlProcessor(String user, String password) {
|
||||||
return new JDBCProcessor("org.postgresql.Driver", "jdbc:postgresql://localhost/template1", user, password);
|
return new JDBCProcessor("org.postgresql.Driver", "jdbc:postgresql://localhost/template1", user, password);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* creates a JDBCProcessor for the PostgreSQL admin user
|
|
||||||
*
|
|
||||||
* @return
|
|
||||||
*/
|
|
||||||
public static JDBCProcessor createPostgreSqlAdminProcessor() {
|
public static JDBCProcessor createPostgreSqlAdminProcessor() {
|
||||||
return new JDBCProcessor("org.postgresql.Driver", "jdbc:postgresql://localhost/template1");
|
return new JDBCProcessor("org.postgresql.Driver", "jdbc:postgresql://localhost/template1");
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* @return a Processor which creates a new database
|
|
||||||
*/
|
|
||||||
public <T extends AbstractEntity> Processor createCreateProcessor(EntityManager em, T entity) {
|
public <T extends AbstractEntity> Processor createCreateProcessor(EntityManager em, T entity) {
|
||||||
Database db = (Database) entity;
|
Database db = (Database) entity;
|
||||||
assert db.getInstance().equals("pgsql");
|
assert db.getInstance().equals("pgsql");
|
||||||
@ -50,9 +29,6 @@ public class PgSqlDatabaseProcessorFactory implements EntityProcessorFactory {
|
|||||||
return aJDBCP;
|
return aJDBCP;
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* @return a Processor which updates a preexisting database
|
|
||||||
*/
|
|
||||||
public <T extends AbstractEntity> Processor createUpdateProcessor(EntityManager em, T entity) {
|
public <T extends AbstractEntity> Processor createUpdateProcessor(EntityManager em, T entity) {
|
||||||
Database db = (Database) entity;
|
Database db = (Database) entity;
|
||||||
assert db.getInstance().equals("pgsql");
|
assert db.getInstance().equals("pgsql");
|
||||||
@ -64,9 +40,6 @@ public class PgSqlDatabaseProcessorFactory implements EntityProcessorFactory {
|
|||||||
return aJDBCP;
|
return aJDBCP;
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* @return a Processor which deletes an existing database
|
|
||||||
*/
|
|
||||||
public <T extends AbstractEntity> Processor createDeleteProcessor(EntityManager em, T entity) {
|
public <T extends AbstractEntity> Processor createDeleteProcessor(EntityManager em, T entity) {
|
||||||
Database db = (Database) entity;
|
Database db = (Database) entity;
|
||||||
assert db.getInstance().equals("pgsql");
|
assert db.getInstance().equals("pgsql");
|
||||||
@ -75,4 +48,5 @@ public class PgSqlDatabaseProcessorFactory implements EntityProcessorFactory {
|
|||||||
aJDBCP.addSQL("DROP DATABASE " + aName);
|
aJDBCP.addSQL("DROP DATABASE " + aName);
|
||||||
return aJDBCP;
|
return aJDBCP;
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user