load config on queue-server
This commit is contained in:
parent
b05e5555f2
commit
a696ddfc31
@ -18,25 +18,24 @@ public class JDBCProcessor extends AbstractProcessor {
|
||||
|
||||
final private String driver;
|
||||
final private String url;
|
||||
final private String user;
|
||||
final private String password;
|
||||
final private List<String> sql;
|
||||
|
||||
private String errorMsg;
|
||||
|
||||
public JDBCProcessor(final String driver, final String url, final String user, final String password) {
|
||||
this.driver = driver;
|
||||
this.url = url;
|
||||
this.user = user;
|
||||
this.password = password;
|
||||
this.errorMsg = "";
|
||||
this.sql = new ArrayList<String>();
|
||||
LOG.info("Constructor 1 - DB-User: " + user + " Password: " + password);
|
||||
}
|
||||
|
||||
public JDBCProcessor(final String driver, final String url) throws ProcessorException {
|
||||
this.driver = driver;
|
||||
this.url = url;
|
||||
this.errorMsg = "";
|
||||
this.sql = new ArrayList<String>();
|
||||
}
|
||||
|
||||
public void addSQL(String sqlStatement) {
|
||||
sql.add(sqlStatement);
|
||||
}
|
||||
|
||||
public Object process() throws ProcessorException {
|
||||
Connection c = null;
|
||||
String user, password;
|
||||
final Config config = Config.getInstance();
|
||||
if ("com.mysql.jdbc.Driver".equals(driver)) {
|
||||
user = config.getProperty("mysqladmin.user", "root");
|
||||
@ -49,17 +48,7 @@ public class JDBCProcessor extends AbstractProcessor {
|
||||
throw new ProcessorException("database admin-user configuration failed");
|
||||
}
|
||||
}
|
||||
LOG.info("Constructor 2 - DB-User: " + user + " Password: " + password);
|
||||
this.errorMsg = "";
|
||||
this.sql = new ArrayList<String>();
|
||||
}
|
||||
|
||||
public void addSQL(String sqlStatement) {
|
||||
sql.add(sqlStatement);
|
||||
}
|
||||
|
||||
public Object process() throws ProcessorException {
|
||||
Connection c = null;
|
||||
LOG.info("process() - DB-User: " + user + " Password: " + password);
|
||||
try {
|
||||
Class.forName(driver);
|
||||
c = DriverManager.getConnection(url, user, password);
|
||||
|
@ -15,11 +15,12 @@ import de.hsadmin.core.qserv.ProcessorException;
|
||||
* @author mi
|
||||
*/
|
||||
public class MySqlDatabaseProcessorFactory implements EntityProcessorFactory {
|
||||
public static JDBCProcessor createMySqlProcessor(String database,
|
||||
String user, String password) {
|
||||
return new JDBCProcessor("com.mysql.jdbc.Driver",
|
||||
"jdbc:mysql://localhost/" + database, user, password);
|
||||
}
|
||||
|
||||
// public static JDBCProcessor createMySqlProcessor(String database,
|
||||
// String user, String password) {
|
||||
// return new JDBCProcessor("com.mysql.jdbc.Driver",
|
||||
// "jdbc:mysql://localhost/" + database, user, password);
|
||||
// }
|
||||
|
||||
public static JDBCProcessor createMySqlAdminProcessor() throws ProcessorException {
|
||||
return new JDBCProcessor("com.mysql.jdbc.Driver", "jdbc:mysql://localhost/");
|
||||
|
@ -10,9 +10,9 @@ import de.hsadmin.core.qserv.ProcessorException;
|
||||
|
||||
public class PgSqlDatabaseProcessorFactory implements EntityProcessorFactory {
|
||||
|
||||
public static JDBCProcessor createPostgreSqlProcessor(String user, String password) {
|
||||
return new JDBCProcessor("org.postgresql.Driver", "jdbc:postgresql://localhost/template1", user, password);
|
||||
}
|
||||
// public static JDBCProcessor createPostgreSqlProcessor(String user, String password) {
|
||||
// return new JDBCProcessor("org.postgresql.Driver", "jdbc:postgresql://localhost/template1", user, password);
|
||||
// }
|
||||
|
||||
public static JDBCProcessor createPostgreSqlAdminProcessor() throws ProcessorException {
|
||||
return new JDBCProcessor("org.postgresql.Driver", "jdbc:postgresql://localhost/template1");
|
||||
|
Loading…
Reference in New Issue
Block a user