sqlbean.java

来自「一个管理系统」· Java 代码 · 共 93 行

package stuman;

import java.io.*;
import java.sql.*;

public class sqlBean {/// 
    public Statement stmt = null;
    public Connection conn = null;
    public ResultSet rs = null;
    private String DatabaseDriver = "com.microsoft.jdbc.sqlserver.SQLServerDriver";
//锟斤拷锟藉方锟斤拷 
/*setXxx锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷值;getXxx锟斤拷锟节得碉拷锟斤拷锟斤拷值*/
    public void setDatabaseDriver(String Driver) {
        this.DatabaseDriver = Driver;
    }

    public String getDatabaseDriver() {
        return (this.DatabaseDriver);
    }

    public sqlBean() {/////锟斤拷锟届函锟斤拷 
        try {
            Class.forName(DatabaseDriver);
        } catch (java.lang.ClassNotFoundException e) {
            System.err.println("锟斤拷锟斤拷锟斤拷锟斤拷锟叫达拷锟斤拷:" + e.getMessage());
            System.out.print("执锟叫诧拷锟斤拷锟叫达拷锟斤拷:" + e.getMessage());//锟斤拷锟酵伙拷锟斤拷 
        }
    }

    public int executeInsert(String sql) {
        int num = 0;
        try {

            conn = DriverManager.getConnection("jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=ClassDB;user=sa;password=");
            Statement stmt = conn.createStatement();
            num = stmt.executeUpdate(sql);
        } catch (SQLException ex) {
            System.err.println("执锟叫诧拷锟斤拷锟叫达拷锟斤拷:" + ex.getMessage());
            System.out.print("执锟叫诧拷锟斤拷锟叫达拷锟斤拷:" + ex.getMessage());//锟斤拷锟酵伙拷锟斤拷 
        }

        CloseDataBase();
        return num;
    }
// display data 
    public ResultSet executeQuery(String sql) {
        try {
            conn = DriverManager.getConnection("jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=ClassDB;user=sa;password=");
            stmt = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY);
            rs = stmt.executeQuery(sql);
        } catch (SQLException ex) {
            System.err.println(ex.getMessage());
        }
        return rs;
    }

    public int executeUpdate(String sql) {
        int result = 0;
        try {
            conn = DriverManager.getConnection("jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=ClassDB;user=sa;password=");
            stmt = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY);
            result = stmt.executeUpdate(sql);
        } catch (SQLException ex) {
            result = 0;
        }
        return result;
    }
    //delete data 
    public int executeDelete(String sql) {
        int num = 0;
        try {
            conn = DriverManager.getConnection("jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=ClassDB;user=sa;password=");

            Statement stmt = conn.createStatement();
            num = stmt.executeUpdate(sql);
        } catch (SQLException ex) {
            System.err.println("执锟斤拷删锟斤拷锟叫达拷锟斤拷:" + ex.getMessage());
            System.out.print("执锟斤拷删锟斤拷锟叫达拷锟斤拷:" + ex.getMessage()); //锟斤拷锟酵伙拷锟斤拷 
        }
        CloseDataBase();
        return num;
    }
////////////////// 
    public void CloseDataBase() {
        try {
            conn.close();
        } catch (Exception end) {
            System.err.println("执锟叫关憋拷Connection锟斤拷锟斤拷锟叫达拷锟斤拷" + end.getMessage());
            System.out.print("执锟斤拷执锟叫关憋拷Connection锟斤拷锟斤拷锟叫达拷锟斤拷锟叫达拷锟斤拷:" + end.getMessage()); //锟斤拷锟酵伙拷锟斤拷 
        }
    }
}