odbcbean.java

这是用JAVA做的一个BOOKSTORE的模拟程序,运行之后的用户名 和密码就靠读者的智慧了 ,从源码里可以找到

package BookStore;

import java.io.*;
import java.sql.*;
import java.util.*;
import javax.naming.*;
import javax.sql.*;


public class ODBCBean implements Serializable{

  Connection conn = null;
  Statement stmt = null;
  ResultSet rs = null;
  DataSource ds = null;

//建立连接，此连接为JDBC－ODBC桥连接，需要先建立名为testODBC的ODBC源
  public void getODBCConnection()
  {
    try
    {
      //加载JDBD-ODBC驱动程序
      Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");

      //用适当的驱动程序连接到DBMS, "testODBC"是系统dsn名
      String url = "jdbc:odbc:testODBC";

      //其中sa与3401是数据库的用户名与密码
      conn = DriverManager.getConnection(url, "sa", "3401");

      //然后创建一个JDBC声明
      stmt = conn.createStatement();

    }
    catch (Exception e)
    {
      System.out.println("getConnection method is Error: " + e.getMessage());
    }
  }

//关闭连接
  public void closeConnect()
  {
    try
    {
      if (rs != null)
        rs.close(); //关闭结果集

      if (stmt != null)
        stmt.close(); //关闭语句对象

      if (conn != null)
        conn.close(); //关闭连接

    }
    catch (Exception e)
    {
      System.out.println("myConnection is Error: " + e.getMessage());
      rs = null;
      stmt = null;
      conn = null;
    }
  }

//查书的数量
  public int queryNum(String bookBH)
  {
    String query = "SELECT * from BookInfo where BookBH ="+bookBH;
    System.out.println(query);
    try
    {
      if (conn == null)
        //先连接数据库
        getODBCConnection();

      System.out.println("connection ok");
      rs = stmt.executeQuery(query);
      System.out.println("query ok");
      int temp = 0;
      while(rs.next())
      {
      temp =  rs.getInt("BookNumber");
      }
      System.out.println("数量为"+temp);

      closeConnect();

      return temp;

    }

    catch (Exception e)
    {
         System.out.println("executeQuery error here: " + e.getMessage());
    }
    closeConnect();
    return 0;
  }

//执行查询sql语句
  public ResultSet selectBookInfo(){
  rs = null;
  String sql = "SELECT * FROM BookInfo";

  try{
    if(conn == null)
      //先连接数据库
      getODBCConnection();

    rs = stmt.executeQuery(sql);  //执行查询sql语句

  }catch(Exception e){
     System.out.println("executeQuery error here: " + e.getMessage());
  }

  return rs;
  }

//执行更新sql语句
  public boolean executeUpdate(String bookBH,int newNum){
    boolean update = false;
    int rowCount = 0;
    newNum--;
    String sql = "UPDATE BookInfo SET BookNumber="+newNum+" WHERE BookBH="+bookBH;
    System.out.println(sql);

    try{
      if(conn == null)
        //如果没连接，先连接数据库连接池
        getODBCConnection();

      if(conn != null){  //有连接，则执行sql更新语句
        stmt = conn.createStatement();
        rowCount = stmt.executeUpdate(sql);
        if(rowCount != 0)

          update = true;
      }

    }catch(SQLException e){
      System.err.println("Conn.executeUpdate " + e.getMessage());
    }
    closeConnect();
    return update;
  }



}