正在阅读：信息系统中用Java访问SQLServer信息系统中用Java访问SQLServer

  作者信息：

  曾青松 zengqingsong@sohu.com
  中山大学数学与计算科学学院 信息系统与计算机网络方向硕士研究生

  程序源代码：

  }

  public Connection getConnection(String userName, String password) throws
      SQLException {
    this.setUserName(userName);
    this.setPassword(password);
    return getConnection();
  }

  public PrintWriter getLogWriter() {
    return null;
  }

  public void setLogWriter(PrintWriter printWriter) {
  }

  public void setLoginTimeout(int int0) {
  }

  public int getLoginTimeout() {
    return 0;
  }
  }

  SqlServerConnectionFactory。
  package skydev.modules.data;
  public final class SqlServerConnectionFactory extends ConnectionFactory {
  private final String dbDriver ="com.microsoft.jdbc.sqlserver.SQLServerDriver";
  private String host;//主机
  private int port;//端口
  private String databaseName;//Sql数据库名称

  public SqlServerConnectionFactory() {
    super.setDriverName(dbDriver);
  }

  /**
   *
   * @param host 数据库所在的主机名：如"localhost"
   * @param port SQL服务器运行的端口号，如果使用缺省值 1433，传入一个负数即可
   * @param databaseName 数据库名称
   * @param userName 用户名
   * @param password 口令
   */
  public SqlServerConnectionFactory(String host,
                                    int port,
                                    String databaseName,
                                    String userName,
                                    String password) {
    this.setHost(host);
    this.setPort(port);
    this.setDatabaseName(databaseName);

  private void init() {
    super.setDriverName(dbDriver);
    super.setUrl("jdbc:microsoft:sqlserver://" + host.trim() + ":" +
                 new Integer(port).toString() + ";DatabaseName=" +
                 databaseName.trim());
    //super.setUrl("jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=demo");
  }

  public void setHost(String host) {
    //处理主机名称
    if ( (host == null) || (host.equals("")) || (host.equals(".")) ||
        (host.equals("local"))) {
      host = "localhost";
    }
    int index = host.indexOf("//", 0);
    if (index == 0) {
      host = host.substring(2); //去掉前面的"//"
    }
    index = host.indexOf("//", 0);
    if (index >= 0) {
      try {
        throw new Exception("SQL Server主机名参数错误！");
      }
      catch (Exception ex) {

  public void setPort(int port) {
    /**
     * 缺省端口1433
     */
    if (port < 0) {
      port = 1433;
    }
    this.port = port;
  }

  public void setDatabaseName(String databaseName) {
    this.databaseName = databaseName;
  }
  }

  使用"sun.jdbc.odbc.JdbcOdbcDriver"连接数据库的连接工厂
  package skydev.modules.data;
  public class JdbcOdbcConnectionFactory extends ConnectionFactory {
  private final static String driveName = "sun.jdbc.odbc.JdbcOdbcDriver";
  private String odbcName;

  public JdbcOdbcConnectionFactory() {
    super.setDriverName(driveName);
  }

  /**

  public void setOdbcName(String odbcName) {
    this.odbcName = odbcName;
    this.setUrl("jdbc:odbc:" + odbcName);
  }
  }

  数据基本操作类，使用连接工厂连接数据库。
  package skydev.modules.data;
  import java.sql.*;
  import java.sql.PreparedStatement;
  import javax.sql.DataSource;

  public abstract class DatabaseObject {
  protected Connection connection = null;
  protected ResultSet resultSet = null;
  protected ResultSetMetaData resultSetMetaData = null;
  private ConnectionFactory connectionFactory = null;
  private java.sql.Statement statement=null;
  private javax.sql.DataSource dataSource;//=new Statement();

  public DatabaseObject(){
    dataSource=null;

  public DatabaseObject(ConnectionFactory connectionFactory) {
    this.setConnectionFactory(connectionFactory);
    this.dataSource=connectionFactory;//ConnectionFactory实现了DataSource接口
  }

  /**
   * 执行查询
   * @param sql 要执行的Sql语句
   * @return　返回查询的结果集 ,查询失败返回null
   */
  public ResultSet getResultSet(String sql) {
    try {
      this.resultSet = statement.executeQuery(sql); //保留内部指针
    }
    catch (SQLException e) {
      e.printStackTrace();
      this.resultSet = null;
    }
    finally {
      return this.resultSet;
    }
  }

  /**
   * 获取外部指定ResltSet的ResultSetMetaData数据
   * @param resultSet 要获取的ResultSet
   * @return 失败返回null

  /**
   * 获取最近一次设置或者返回的ResultSet的ResultMetaData数据，
   * 比方说调用了：getResultSet(sql)方法，然后调用getResultSetMetaData方法
   * 可以获得相应的ResultSetMetaData数据。
   * @return
   */
  public ResultSetMetaData getResultSetMetaData() {
    return this.getResultSetMetaData(this.resultSet);
  }

  /**
   * 执行存储过程
   * @param spName 存储过程名称
   * @return
   */
  public ResultSet Execute(String spName) {

  /**
   * 设置数据库连接工厂，对此类的所有操作之前，必须调用该方法，
   * 设置数据库连接工厂。
   * @param connectionFactory 数据库连接工厂ConnectionFactory 类对象以及
   * 派生类对象。
   */
    public void setConnectionFactory(ConnectionFactory connectionFactory) {
    this.connectionFactory = connectionFactory;
    connection = connectionFactory.getConnection();
    try {
      statement = connection.createStatement();
    }
    catch (SQLException ex) {
      System.err.println(ex);
    }
  }

  public Connection getConnection() {

  public java.sql.Statement getStatement() {
    return statement;
  }
  public javax.sql.DataSource getDataSource() {
    return dataSource;
  }
  }

  具体项目的数据库访问基类
  package skydev.modules.data;
  public class DbObject extends DatabaseObject {
   // private final static String driveName = "sun.jdbc.obdc.JdbcOdbcDriver";
    public DbObject() {
    super(new SqlServerConnectionFactory("localhost", 1433, "TheSchool", "sa",""));
    }

    public DbObject(ConnectionFactory connectionFactory) {
    super(connectionFactory);
  }
  }

  在项目中的数据库层中的数据库访问类都从DatabaseObject类派生，这样只需要在一个地方设置数据连接，其他地方都不需要涉及数据库访问的具体连接代码。
如：User类专门负责Users组的权限控制等，只需要简单的代码就可以连接并访问数据库了。这里具体实现与此文章无关，只举一两个模块做例子。