dboperate.java

来自「基于mvc的宠物管理系统。servlet+jsp」· Java 代码 · 共 110 行

package com.richard.dao;

import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.Statement;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.*;

public class DBOperate {

    Connection conn;
    Statement sta;
    PreparedStatement pre;
    ResultSet rs;

    public DBOperate() {
    }

    /*****************************************************************/
    //一个用于返回Connection的函数
    public Connection getConnect(String dbname) {
        String url =
                "jdbc:microsoft:sqlserver://127.0.0.1:1433;DatabaseName=";
        try {
            Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver");
        } catch (Exception ex) {
            ex.printStackTrace();
        }
        try {
            conn = DriverManager.getConnection(url + dbname,"sa","");
        } catch (Exception ex) {
            ex.printStackTrace();
        }
        return conn;
    }

    /*****************************************************************/
    //一个用于返回Statement的函数
    public Statement getStatement(String dbname) {
        String url =
                "jdbc:microsoft:sqlserver://127.0.0.1:1433;DatabaseName=";
        try {
            Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver");
        } catch (Exception ex) {
            ex.printStackTrace();
        }
        try {
            conn = DriverManager.getConnection(url + dbname,"sa","");
            sta = conn.createStatement();
        } catch (Exception ex) {
            ex.printStackTrace();
        }
        return sta;
    }

    /*****************************************************************/
    //用于返回PreparedStatement
    public PreparedStatement getPreparedStatement(String dbname, String usrsql) {
        String url =
                "jdbc:microsoft:sqlserver://127.0.0.1:1433;DatabaseName=";
        try {
            Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver");
        } catch (Exception ex) {
            ex.printStackTrace();
        }
        try {
            conn = DriverManager.getConnection(url + dbname,"sa","");
            pre = conn.prepareStatement(usrsql);
        } catch (Exception ex) {
            ex.printStackTrace();
        }
        return pre;
    }

    /***************************************************************/
    //用于返回ResultSet
    public ResultSet getResultSet(String dbname, String mysql) {
        String url =
                "jdbc:microsoft:sqlserver://127.0.0.1:1433;DatabaseName=";
        try {
            Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver");
        } catch (Exception ex) {
            ex.printStackTrace();
        }
        try {
            conn = DriverManager.getConnection(url + dbname,"sa","");
            sta = conn.createStatement();
            rs = sta.executeQuery(mysql);

        } catch (Exception ex) {
            ex.printStackTrace();
        }
        return rs;

    }

    //用于执行sql语句
    public void exeSql(String dbName,String sqlCommand)
    {
        sta=getStatement(dbName);
        try {
            sta.execute(sqlCommand);
        } catch (SQLException ex) {
            ex.printStackTrace();
        }
    }

}