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