insertdatatest.java

ACCP 软件工程java 教程学生用书

/**
  * (c)北大青鸟APTECH
  * 版权所有
  */


import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.IOException;
import java.sql.SQLException;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.PreparedStatement;

/**
  * 这个类使用 Prepared Statement 搜索记录.
  * @version 1.0, 2005 年 6 月 15 日
  * @author Michael
  */

class InsertData {

/** 声明一个 statement 对象.*/
    private ResultSet resultObj;

    /** 声明一个 string 变量.*/
    private String strTemp , strSql;

    /** 声明一个 PreparedStatement 对象.*/
    private PreparedStatement pst;

    /** 声明一个 int 变量.*/
    private int qty;

    /** 声明一个 BufferedReader 对象.*/
    private BufferedReader bufferObj;

    /** 声明一个 connection 变量.*/
    private Connection con;

    /** 声明一个 string 变量以容纳 URL.*/
    private String url;

    /** 声明一个 string 变量以存储 serverName.*/
    private String serverName;

    /** 声明一个 string 变量以容纳端口号.*/
    private String portNumber;

    /** 声明一个 string 变量以存储数据库名称.*/
    private String databaseName;

    /** 声明一个 string 变量以存储用户名称.*/
    private String userName;

    /** 声明一个 string 变量以存储密码.*/
    private String password;

    /** 构造函数. */
    public InsertData() {
        bufferObj = new BufferedReader(new InputStreamReader(System.in));
        con = getConnection();
    }


    /** 初始化变量的方法.
     * @return String 值
     */
    private String getConnectionUrl() {

        url = "jdbc:microsoft:sqlserver://";
        serverName = "127.0.0.1";
        portNumber = "1433";
        databaseName = "master";
        userName = "sa";
        password = "";
        return url + serverName + ":" + portNumber
         + ";databaseName=" + databaseName + ";";
    }

    /** 建立连接的方法.
     * @return Connection 对象
     */
    private java.sql.Connection getConnection() {

        try {
             Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver");
             con = java.sql.DriverManager.getConnection(getConnectionUrl() ,
 userName , password);

             if (con != null) {
                System.out.println("连接成功!");
             }
        } catch (Exception e) {
             e.printStackTrace();
        }
            return con;
    }

    /**
      * 使用插入行的方法添加记录.
      * @throws IOException 对象
      */

    void add() throws IOException {
          System.out.println();
          try {
             strSql = "Select * from Staff";
             pst = con.prepareStatement(strSql ,
ResultSet.TYPE_SCROLL_SENSITIVE , ResultSet.CONCUR_UPDATABLE);
             resultObj = pst.executeQuery();

             System.out.print("\n请输入雇员号: ");
             int id = Integer.parseInt(bufferObj.readLine());

             System.out.print("\n请输入雇员名称: ");
             String name = bufferObj.readLine();

             System.out.print("\n请输入雇员地址: ");
             String address = bufferObj.readLine();

             System.out.print("\n请输入雇员的工资: ");
             float salary = Float.parseFloat(bufferObj.readLine());

             System.out.print("\n请输入雇员的电话号码: ");
             int phone = Integer.parseInt(bufferObj.readLine());

             System.out.print("\n请输入雇员的部门: ");
             String dept = bufferObj.readLine();

             resultObj.moveToInsertRow();

             resultObj.updateInt("Employee_Id", id);
             resultObj.updateString("Employee_Name", name);
             resultObj.updateString("Employee_Address", address);
             resultObj.updateFloat("Employee_Salary", salary);
             resultObj.updateInt("Employee_Phone", phone);
             resultObj.updateString("Employee_Dept", dept);

             resultObj.insertRow();
             resultObj.beforeFirst();
             strSql = "Select * from Staff Order By Employee_Dept";
             pst = con.prepareStatement(strSql ,
ResultSet.TYPE_SCROLL_SENSITIVE , ResultSet.CONCUR_UPDATABLE);
             resultObj = pst.executeQuery();
             System.out.println();
             System.out.println("插入 Staff 表后:");
             while (resultObj.next()) {
                 System.out.print(resultObj.getInt(1) + "\t");
                 System.out.print(resultObj.getString(2) + "\t\t");
                 System.out.print(resultObj.getString(3) + "\t\t");
                 System.out.print(resultObj.getFloat(4) + "\t\t");
                 System.out.print(resultObj.getInt(5) + "\t\t");
                 System.out.print(resultObj.getString(6) + "\t\t");
                 System.out.println();
             }
             resultObj.close();
             con.close();
         } catch (SQLException ce) {
               ce.printStackTrace();
               System.out.println(ce);
         }
     }
}


/**
  * 这个类使用 Prepared Statement 搜索记录.
  * @version 1.0, 2005 年 6 月 15 日
  * @author Michael
  */


class InsertDataTest {


    /**
      * 构造函数. */
    protected InsertDataTest() {
    }

    /**
     * 这是执行任何应用程序的起始点.
     * @param args 被传递至 main 方法
     * @throws IOException 对象
     */

    public static void main(String[] args) throws IOException {
        InsertData dataObj = new InsertData();
        dataObj.add();
    }
}