createmanipulatestoredprocedure.java~13~

jbuilder2006一书的所有源代码

package dataexpress;

import java.sql.*;

public class CreateManipulateStoredProcedure {

  public static void main(String[] args) throws Exception {
    //声明连接类
    Connection conn;
    //声明Sql语句执行类
    Statement statement;
    //定义数据库连接的驱动程序
    String driver = "com.microsoft.jdbc.sqlserver.SQLServerDriver";
    //定义SQLServer数据库的连接地址
    String url = "jdbc:microsoft:sqlserver://bemyfriend:1433;DatabaseName="
        + "books;User=sa;Password=";
    //注册驱动程序
    Class.forName(driver);
    //第一个参数定义用户名,第二个参数定义密码
    conn = DriverManager.getConnection(url, "sa", "");
    //创建sql语句执行类
    statement = conn.createStatement();
    String createProcedure;
    try{
      //创建insert存储语句的字符串
      createProcedure = "create procedure insertbookcategory as " +
                        "insert into bookcategory values('14', '图书类别14', '图书类别14的描述')";
      //向数据库写入存储语句
      statement.executeUpdate(createProcedure);
      System.out.println("成功添加insert存储语句.");
      //创建delete存储语句的字符串
      createProcedure = "create procedure deletebookcategory as " +
                        "delete from bookcategory where CompanyName = '新增加的公司'";
      //向数据库写入存储语句
      statement.executeUpdate(createProcedure);
      System.out.println("成功添加delete存储语句.");
      //创建update存储语句的字符串
      createProcedure = "create procedure updatebookcategory as " +
                        "update bookcategory set phone ='111-11111' " +
                        "where CompanyName = '新增加的公司'";
      //向数据库写入存储语句
      statement.executeUpdate(createProcedure);
      System.out.println("成功添加update存储语句.");
    }
    catch (Exception e) {
      e.printStackTrace();
    }
    //关闭sql语句执行类
    statement.close();
    //关闭数据库连接类
    conn.close();
  }
}