public class Source
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
ACCESS |
static java.lang.String |
DB2 |
static java.lang.String |
EXCEL |
static java.lang.String |
MYSQL |
static java.lang.String |
ODDBC |
static java.lang.String |
ORACLE |
static java.lang.String |
POSTGRESQL9 |
static java.lang.String |
SELECT_CURSOR |
static java.lang.String |
SELECT_DIRECT |
static java.lang.String |
SQL_SERVER_2005 |
static java.lang.String |
SQL_SERVER_2008 |
Constructor and Description |
---|
Source(ICdmDataSource cdmDataSource)
Creates a source with parameters of a ICdmDataSource instance
|
Source(java.lang.String dbms,
java.lang.String server,
java.lang.String db)
Creates a source and sets the according variables
|
Source(java.lang.String dbms,
java.lang.String server,
java.lang.String db,
boolean cursor)
Creates a source and sets the parameter.
|
Source(java.lang.String dbms,
java.lang.String server,
java.lang.String db,
int port)
Creates a source and sets the parameter.
|
Source(java.lang.String dbms,
java.lang.String server,
java.lang.String db,
java.lang.String query)
Creates a source and sets the query string
|
Modifier and Type | Method and Description |
---|---|
boolean |
checkColumnExists(java.lang.String tableName,
java.lang.String dbAttribute)
Checks if an attribute exists in the database schema.
|
java.sql.Connection |
getConnection()
Returns the connection.
|
java.lang.String |
getDatabase() |
java.sql.ResultSet |
getResultSet()
Returns the Resultset for Sources query.
|
java.sql.ResultSet |
getResultSet(java.lang.String query)
Returns the Resultset for query 'query'.
|
java.lang.String |
getServer() |
int |
getUniqueInteger(java.lang.String query) |
java.lang.Object |
getUniqueResult(java.lang.String query) |
boolean |
isDoLog() |
void |
setDoLog(boolean doLog) |
Source |
setPassword(java.lang.String pwd)
Sets the password.
|
Source |
setPort(int port)
Sets the port.
|
Source |
setQuery(java.lang.String query) |
Source |
setUserAndPwd(java.lang.String userName,
java.lang.String pwd)
Sets the username and password.
|
Source |
setUsername(java.lang.String userName)
Sets the username.
|
java.lang.String |
toString() |
int |
update(java.lang.String updateStatement)
Executes an insert, update or delete statement.
|
public static final java.lang.String SQL_SERVER_2005
public static final java.lang.String SQL_SERVER_2008
public static final java.lang.String ACCESS
public static final java.lang.String EXCEL
public static final java.lang.String ODDBC
public static final java.lang.String ORACLE
public static final java.lang.String DB2
public static final java.lang.String POSTGRESQL9
public static final java.lang.String MYSQL
public static final java.lang.String SELECT_DIRECT
public static final java.lang.String SELECT_CURSOR
public Source(java.lang.String dbms, java.lang.String server, java.lang.String db)
dbms
- name of database management system (e.g. "SQLServer", "Access", "Excel", "Oracle"server
- name of server, if dbms is ODBC, this must be the ODBC namedb
- name of databasepublic Source(java.lang.String dbms, java.lang.String server, java.lang.String db, java.lang.String query)
dbms
- name of database management system (e.g. "SQLServer", "Access", "Excel", "Oracle"server
- name of server, if dbms is ODBC, this must be the ODBC namedb
- name of databasequery
- the querypublic Source(java.lang.String dbms, java.lang.String server, java.lang.String db, boolean cursor)
cursor
- access mode, if true 'cursor', if false 'direct'public Source(java.lang.String dbms, java.lang.String server, java.lang.String db, int port)
dbms
- name of database management system (e.g. "SQLServer", "Access", "Excel", "Oracle"server
- name of server, if dbms is ODBC, this must be the ODBC namedb
- name of databaseport
- the databases port (-1: use default port)public Source(ICdmDataSource cdmDataSource)
cdmDataSource
- public java.sql.ResultSet getResultSet(java.lang.String query)
public java.lang.Object getUniqueResult(java.lang.String query)
public int getUniqueInteger(java.lang.String query)
public int update(java.lang.String updateStatement)
public java.sql.ResultSet getResultSet()
public java.sql.Connection getConnection()
public Source setQuery(java.lang.String query)
query
- public Source setUsername(java.lang.String userName)
userName
- public Source setPassword(java.lang.String pwd)
pwd
- public Source setUserAndPwd(java.lang.String userName, java.lang.String pwd)
userName
- pwd
- public Source setPort(int port)
userName
- pwd
- public java.lang.String getDatabase()
public java.lang.String getServer()
public boolean isDoLog()
public void setDoLog(boolean doLog)
public boolean checkColumnExists(java.lang.String tableName, java.lang.String dbAttribute) throws DatabaseTypeNotSupportedException
tableName
- dbAttribute
- org.apache.http.MethodNotSupportedException
DatabaseTypeNotSupportedException
public java.lang.String toString()
toString
in class java.lang.Object
Copyright © 2007-2020 EDIT. All Rights Reserved.