src/jdbc/JdbcSqlDataSource.java

   1 package csql.jdbc;
   2
   3 import java.util.*;
   4 import java.sql.*;
   5 import javax.sql.*;
   6 import javax.naming.*;
   7 import java.io.*;
   8 import java.lang.*;
   9 import java.lang.Class;
  10 //import java.sql.SQLException;
  11
  12 public class JdbcSqlDataSource implements javax.sql.DataSource, javax.naming.Referenceable, java.io.Serializable
  13 {
  14     static
  15     {
  16         try
  17         {
  18             DriverManager.registerDriver(new JdbcSqlDriver());
  19         }
  20         catch (Exception e)
  21         {
  22             System.out.println ("CSql JDBC Driver: " + e);
  23         }
  24     }
  25
  26     private String databaseName="csql";
  27     private String dataSourceName;
  28     private String serverName="localhost";
  29     private String password="manager";
  30     private String userName="root";
  31     private String mode="";
  32     transient JdbcSqlDriver driver;
  33     transient private PrintWriter printer;
  34     private int loginTimeout;
  35     private String jdbcurl="jdbc:";
  36     private int portno = 5678;
  37     boolean explicityUrlUsed=false;
  38     private String explicityUrl="";
  39     public JdbcSqlDataSource()
  40     {
  41
  42     }
  43
  44
  45 /* Connection*/
  46     public Connection getConnection() throws SQLException
  47     {
  48         return this.getConnection(getUserName(),getPassword());
  49     }
  50     public synchronized Connection getConnection(String username, String password) throws SQLException
  51     {
  52         String url="";
  53         if(!explicityUrlUsed){
  54             url = jdbcurl+ mode +"://" + serverName + ":" + portno +"/" + databaseName;
  55         } else {
  56             url = explicityUrl;
  57         }
  58         Properties info = new Properties();
  59         if (username != null)
  60             info.put("user", username);
  61         if (password != null)
  62             info.put("password", password);
  63         Connection conn =  findDriver().connect(url, info);
  64       /*  if (conn == null)
  65            throw ;*/
  66         return conn;
  67
  68     }
  69     public void setUrl(String url)
  70     {
  71          if(explicityUrlUsed) {
  72             explicityUrl = url;
  73          }
  74     }
  75     public String getUrl()
  76     {
  77         String url="";
  78         if(!explicityUrlUsed){
  79             url = jdbcurl+ mode +"://" + serverName + ":" + portno +"/" + databaseName;
  80         } else {
  81             url = explicityUrl;
  82         }
  83         return url;
  84     }
  85
  86     public void setPort(int port)
  87     {
  88          this.portno = port;
  89     }
  90     public int getPort()
  91     {
  92          return this.portno ;
  93     }
  94
  95     public void setMode(String mode)
  96     {
  97          this.mode = mode;
  98     }
  99     public String getMode()
 100     {
 101          return this.mode ;
 102     }
 103
 104     JdbcSqlDriver findDriver() throws SQLException
 105     {
 106         String url = getUrl();
 107         if (driver == null || !driver.acceptsURL(url))
 108         {
 109             //new JdbcSqlDriver();
 110             driver=(JdbcSqlDriver) DriverManager.getDriver(url);
 111         }
 112         return driver;
 113     }
 114     public java.io.PrintWriter getLogWriter()  throws SQLException
 115     {
 116         return printer;
 117     }
 118
 119     public void setLogWriter(java.io.PrintWriter out)
 120     {
 121         printer = out;
 122     }
 123
 124     public void setLoginTimeout(int seconds)throws SQLException
 125     {
 126                 loginTimeout = seconds;
 127
 128     }
 129
 130     public int getLoginTimeout()
 131     {
 132         return loginTimeout;
 133     }
 134
 135     public Reference getReference() throws NamingException
 136     {
 137         Reference ref = new Reference(this.getClass().getName(),"csql.jdbc.JdbcSqlObjectFactory", null);
 138         ref.add( new StringRefAddr("serverName", getServerName()) );
 139         ref.add( new StringRefAddr("databaseName",getDatabaseName()));
 140         ref.add( new StringRefAddr("mode",getMode()));
 141         ref.add( new StringRefAddr("port",""+getPort()));
 142         ref.add( new StringRefAddr("user",getUserName()));
 143         ref.add( new StringRefAddr("password",getPassword()));
 144         ref.add( new StringRefAddr("url",getUrl()));
 145         return ref;
 146     }
 147
 148
 149     public String getServerName(){
 150         return serverName;
 151     }
 152
 153     public void setServerName(String serverName){
 154         this.serverName=serverName;
 155     }
 156
 157     public String getDatabaseName(){
 158         return databaseName;
 159     }
 160
 161     public void setDatabaseName(String databaseName){
 162         this.databaseName=databaseName;
 163     }
 164
 165     public String getUserName()
 166     {
 167         return userName;
 168     }
 169
 170     public void setUserName(String un)
 171     {
 172         this.userName=un;
 173     }
 174
 175     public String getPassword()
 176     {
 177         return password;
 178     }
 179
 180     public void setPassword(String pw)
 181     {
 182         this.password=pw;
 183     }
 184
 185     public boolean isWrapperFor(Class ifact) throws SQLException
 186     {
 187
 188        return ifact.isInstance(this);
 189     }
 190
 191     public <T> T unwrap(java.lang.Class<T> iface) throws SQLException
 192     {
 193             return iface.cast(this);
 194     }
 195
 196 }