java/sql-dk/src/info/globalcode/sql/dk/DatabaseConnection.java
branchv_0
changeset 106 e9c3583580c8
parent 91 43e8d52091d5
child 107 8189a4a28cd8
     1.1 --- a/java/sql-dk/src/info/globalcode/sql/dk/DatabaseConnection.java	Tue Dec 31 18:11:50 2013 +0100
     1.2 +++ b/java/sql-dk/src/info/globalcode/sql/dk/DatabaseConnection.java	Wed Jan 01 01:06:38 2014 +0100
     1.3 @@ -19,6 +19,7 @@
     1.4  
     1.5  import info.globalcode.sql.dk.batch.Batch;
     1.6  import info.globalcode.sql.dk.configuration.DatabaseDefinition;
     1.7 +import info.globalcode.sql.dk.configuration.Properties;
     1.8  import info.globalcode.sql.dk.formatting.ColumnsHeader;
     1.9  import info.globalcode.sql.dk.formatting.Formatter;
    1.10  import java.sql.Connection;
    1.11 @@ -39,11 +40,18 @@
    1.12  	private static final Logger log = Logger.getLogger(DatabaseConnection.class.getName());
    1.13  	private DatabaseDefinition databaseDefinition;
    1.14  	private Connection connection;
    1.15 +	private Properties properties;
    1.16  
    1.17 -	public DatabaseConnection(DatabaseDefinition databaseDefinition) throws SQLException {
    1.18 +	public DatabaseConnection(DatabaseDefinition databaseDefinition, Properties properties) throws SQLException {
    1.19  		this.databaseDefinition = databaseDefinition;
    1.20 +		this.properties = properties;
    1.21  
    1.22 -		connection = DriverManager.getConnection(databaseDefinition.getUrl(), databaseDefinition.getUserName(), databaseDefinition.getPassword());
    1.23 +		properties.setDefaults(databaseDefinition.getProperties());
    1.24 +		java.util.Properties javaProperties = properties.getJavaProperties();
    1.25 +		javaProperties.setProperty("user", databaseDefinition.getUserName());
    1.26 +		javaProperties.setProperty("password", databaseDefinition.getPassword());
    1.27 +
    1.28 +		connection = DriverManager.getConnection(databaseDefinition.getUrl(), javaProperties);
    1.29  	}
    1.30  
    1.31  	public void executeQuery(SQLCommand sqlCommand, Formatter formatter) throws SQLException {