water.jdbc

Class SQLManager

java.lang.Object

water.jdbc.SQLManager

public class SQLManager
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
SQLManager()

Method Summary

Modifier and Type	Method and Description
static java.sql.Connection	getConnectionSafe(java.lang.String url, java.lang.String username, java.lang.String password) Makes sure the appropriate database driver is initialized before calling DriverManager#getConnection.
static Job<Frame>	importSqlTable(java.lang.String connection_url, java.lang.String table, java.lang.String select_query, java.lang.String username, java.lang.String password, java.lang.String columns, java.lang.Boolean useTempTable, java.lang.String tempTableName, SqlFetchMode fetchMode, java.lang.Integer numChunksHint)
static void	validateJdbcUrl(java.lang.String jdbcUrl)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SQLManager

public SQLManager()

Method Detail

importSqlTable

public static Job<Frame> importSqlTable(java.lang.String connection_url,
                                        java.lang.String table,
                                        java.lang.String select_query,
                                        java.lang.String username,
                                        java.lang.String password,
                                        java.lang.String columns,
                                        java.lang.Boolean useTempTable,
                                        java.lang.String tempTableName,
                                        SqlFetchMode fetchMode,
                                        java.lang.Integer numChunksHint)

Parameters:

connection_url - (Input)

table - (Input)

select_query - (Input)

username - (Input)

password - (Input)

columns - (Input)

fetchMode - (Input)

numChunksHint - (optional) Specifies the desired number of chunks for the target Frame

getConnectionSafe

public static java.sql.Connection getConnectionSafe(java.lang.String url,
                                                    java.lang.String username,
                                                    java.lang.String password)
                                             throws java.sql.SQLException

Makes sure the appropriate database driver is initialized before calling DriverManager#getConnection.

Parameters:

url - JDBC connection string

username - username

password - password

Returns:

a connection to the URL

Throws:

java.sql.SQLException - if a database access error occurs or the url is

validateJdbcUrl

public static void validateJdbcUrl(java.lang.String jdbcUrl)
                            throws java.lang.IllegalArgumentException

Throws:

java.lang.IllegalArgumentException