Package net.sourceforge.jtds.jdbcx

Class JtdsDataSource

java.lang.Object
net.sourceforge.jtds.jdbcx.JtdsDataSource
All Implemented Interfaces:
Serializable, Wrapper, Referenceable, CommonDataSource, ConnectionPoolDataSource, DataSource, XADataSource
public class JtdsDataSource extends Object implements DataSource, ConnectionPoolDataSource, XADataSource, Referenceable, Serializable
The jTDS DataSource, ConnectionPoolDataSource and XADataSource implementation.
Since:
jTDS 0.3
Author:
Alin Sinplean, Holger Rehn
See Also:

  • Field Details

    • serialVersionUID

      static final long serialVersionUID
      serial version UID
      See Also:

    • DESCRIPTION

      static final String DESCRIPTION
      See Also:

    • _Config

      private final HashMap _Config

    • _Driver

      private static final Driver _Driver
      Driver instance used for obtaining connections.

  • Constructor Details

    • JtdsDataSource

      JtdsDataSource(HashMap config)
      Constructs a configured DataSource.

    • JtdsDataSource

      public JtdsDataSource()
      Constructs a new DataSource.

  • Method Details

    • getXAConnection

      public XAConnection getXAConnection() throws SQLException
      Returns a new XA database connection.
      Specified by:
      getXAConnection in interface XADataSource
      Returns:
      a new database connection
      Throws:
      SQLException - if an error occurs

    • getXAConnection

      public XAConnection getXAConnection(String user, String password) throws SQLException
      Returns a new XA database connection for the user and password specified.
      Specified by:
      getXAConnection in interface XADataSource
      Parameters:
      user - the user name to connect with
      password - the password to connect with
      Returns:
      a new database connection
      Throws:
      SQLException - if an error occurs

    • getConnection

      public Connection getConnection() throws SQLException
      Returns a new database connection.
      Specified by:
      getConnection in interface DataSource
      Returns:
      a new database connection
      Throws:
      SQLException - if an error occurs

    • getConnection

      public Connection getConnection(String user, String password) throws SQLException
      Returns a new database connection for the user and password specified.
      Specified by:
      getConnection in interface DataSource
      Parameters:
      user - the user name to connect with
      password - the password to connect with
      Returns:
      a new database connection
      Throws:
      SQLException - if an error occurs

    • getReference

      public Reference getReference()
      Specified by:
      getReference in interface Referenceable

    • getPooledConnection

      public PooledConnection getPooledConnection() throws SQLException
      Returns a new pooled database connection.
      Specified by:
      getPooledConnection in interface ConnectionPoolDataSource
      Returns:
      a new pooled database connection
      Throws:
      SQLException - if an error occurs

    • getPooledConnection

      public PooledConnection getPooledConnection(String user, String password) throws SQLException
      Returns a new pooled database connection for the user and password specified.
      Specified by:
      getPooledConnection in interface ConnectionPoolDataSource
      Parameters:
      user - the user name to connect with
      password - the password to connect with
      Returns:
      a new pooled database connection
      Throws:
      SQLException - if an error occurs

    • setLogWriter

      public void setLogWriter(PrintWriter out)
      Specified by:
      setLogWriter in interface CommonDataSource
      Specified by:
      setLogWriter in interface ConnectionPoolDataSource
      Specified by:
      setLogWriter in interface DataSource
      Specified by:
      setLogWriter in interface XADataSource

    • getLogWriter

      public PrintWriter getLogWriter()
      Specified by:
      getLogWriter in interface CommonDataSource
      Specified by:
      getLogWriter in interface ConnectionPoolDataSource
      Specified by:
      getLogWriter in interface DataSource
      Specified by:
      getLogWriter in interface XADataSource

    • setLoginTimeout

      public void setLoginTimeout(int loginTimeout)
      Specified by:
      setLoginTimeout in interface CommonDataSource
      Specified by:
      setLoginTimeout in interface ConnectionPoolDataSource
      Specified by:
      setLoginTimeout in interface DataSource
      Specified by:
      setLoginTimeout in interface XADataSource

    • getLoginTimeout

      public int getLoginTimeout()
      Specified by:
      getLoginTimeout in interface CommonDataSource
      Specified by:
      getLoginTimeout in interface ConnectionPoolDataSource
      Specified by:
      getLoginTimeout in interface DataSource
      Specified by:
      getLoginTimeout in interface XADataSource

    • setSocketTimeout

      public void setSocketTimeout(int socketTimeout)

    • getSocketTimeout

      public int getSocketTimeout()

    • setSocketKeepAlive

      public void setSocketKeepAlive(boolean socketKeepAlive)

    • getSocketKeepAlive

      public boolean getSocketKeepAlive()

    • setProcessId

      public void setProcessId(String processId)

    • getProcessId

      public String getProcessId()

    • setDatabaseName

      public void setDatabaseName(String databaseName)

    • getDatabaseName

      public String getDatabaseName()

    • setDescription

      public void setDescription(String description)

    • getDescription

      public String getDescription()

    • setPassword

      public void setPassword(String password)

    • getPassword

      public String getPassword()

    • setPortNumber

      public void setPortNumber(int portNumber)

    • getPortNumber

      public int getPortNumber()

    • setServerName

      public void setServerName(String serverName)

    • getServerName

      public String getServerName()

    • setAutoCommit

      public void setAutoCommit(boolean autoCommit)

    • getAutoCommit

      public boolean getAutoCommit()

    • setUser

      public void setUser(String user)

    • getUser

      public String getUser()

    • setTds

      public void setTds(String tds)

    • getTds

      public String getTds()

    • setServerType

      public void setServerType(int serverType)

    • getServerType

      public int getServerType()

    • setDomain

      public void setDomain(String domain)

    • getDomain

      public String getDomain()

    • setUseNTLMV2

      public void setUseNTLMV2(boolean usentlmv2)

    • getUseNTLMV2

      public boolean getUseNTLMV2()

    • setUseKerberos

      public void setUseKerberos(boolean useKerberos)

    • getUseKerberos

      public boolean getUseKerberos()

    • setInstance

      public void setInstance(String instance)

    • getInstance

      public String getInstance()

    • setSendStringParametersAsUnicode

      public void setSendStringParametersAsUnicode(boolean sendStringParametersAsUnicode)

    • getSendStringParametersAsUnicode

      public boolean getSendStringParametersAsUnicode()

    • setNamedPipe

      public void setNamedPipe(boolean namedPipe)

    • getNamedPipe

      public boolean getNamedPipe()

    • setLastUpdateCount

      public void setLastUpdateCount(boolean lastUpdateCount)

    • getLastUpdateCount

      public boolean getLastUpdateCount()

    • setXaEmulation

      public void setXaEmulation(boolean xaEmulation)

    • getXaEmulation

      public boolean getXaEmulation()

    • setCharset

      public void setCharset(String charset)

    • getCharset

      public String getCharset()

    • setLanguage

      public void setLanguage(String language)

    • getLanguage

      public String getLanguage()

    • setMacAddress

      public void setMacAddress(String macAddress)

    • getMacAddress

      public String getMacAddress()

    • setPacketSize

      public void setPacketSize(int packetSize)

    • getPacketSize

      public int getPacketSize()

    • setTcpNoDelay

      public void setTcpNoDelay(boolean tcpNoDelay)

    • getTcpNoDelay

      public boolean getTcpNoDelay()

    • setPrepareSql

      public void setPrepareSql(int prepareSql)

    • getPrepareSql

      public int getPrepareSql()

    • setLobBuffer

      public void setLobBuffer(long lobBuffer)

    • getLobBuffer

      public long getLobBuffer()

    • setMaxStatements

      public void setMaxStatements(int maxStatements)

    • getMaxStatements

      public int getMaxStatements()

    • setAppName

      public void setAppName(String appName)

    • getAppName

      public String getAppName()

    • setProgName

      public void setProgName(String progName)

    • getProgName

      public String getProgName()

    • setWsid

      public void setWsid(String wsid)

    • getWsid

      public String getWsid()

    • setLogFile

      public void setLogFile(String logFile)

    • getLogFile

      public String getLogFile()

    • setSsl

      public void setSsl(String ssl)

    • getSsl

      public String getSsl()

    • setBatchSize

      public void setBatchSize(int batchSize)

    • getBatchSize

      public int getBatchSize()

    • setBufferDir

      public void setBufferDir(String bufferDir)

    • getBufferDir

      public String getBufferDir()

    • getBufferMaxMemory

      public int getBufferMaxMemory()

    • setBufferMaxMemory

      public void setBufferMaxMemory(int bufferMaxMemory)

    • setBufferMinPackets

      public void setBufferMinPackets(int bufferMinPackets)

    • getBufferMinPackets

      public int getBufferMinPackets()

    • setCacheMetaData

      public void setCacheMetaData(boolean cacheMetaData)

    • getCacheMetaData

      public boolean getCacheMetaData()

    • setUseCursors

      public void setUseCursors(boolean useCursors)

    • getUseCursors

      public boolean getUseCursors()

    • setUseLOBs

      public void setUseLOBs(boolean useLOBs)

    • getUseLOBs

      public boolean getUseLOBs()

    • setBindAddress

      public void setBindAddress(String bindAddress)

    • getBindAddress

      public String getBindAddress()

    • setUseJCIFS

      public void setUseJCIFS(boolean useJCIFS)

    • getUseJCIFS

      public boolean getUseJCIFS()

    • addNonNullProperties

      private void addNonNullProperties(Properties props, String user, String password)

    • getIntProperty

      private int getIntProperty(String key)

    • getLongProperty

      private long getLongProperty(String key)

    • isWrapperFor

      public boolean isWrapperFor(Class arg0)
      Specified by:
      isWrapperFor in interface Wrapper

    • unwrap

      public Object unwrap(Class arg0)
      Specified by:
      unwrap in interface Wrapper

    • getParentLogger

      public Logger getParentLogger() throws SQLFeatureNotSupportedException
      Specified by:
      getParentLogger in interface CommonDataSource
      Throws:
      SQLFeatureNotSupportedException