자바 링크 my sql 및 sqlserver 추가 삭제 검사

자바 jdbc 를 이용 하여 데이터 베 이 스 를 조작 합 니 다.
MySql:mysql-connector-java-5.1.12-bin.jar
SqlService:sqljdbc4.jar
import com.sun.org.apache.xpath.internal.SourceTree;
import com.sun.xml.internal.ws.api.server.LazyMOMProvider;

import java.sql.*;

/**
 * Created by sunmig on 2016/11/7.
 */
public class SqlHelper {

    /**
     * MYSQL
     *          
     */
    private static String driverName = "com.mysql.jdbc.Driver";
    private static String dbUrl = "jdbc:mysql://localhost:3306/ngxykjc?characterEncoding=UTF-8";
    private static String userName = "root";
    private static String userPwd = "lalala";

    /***
     * SQLSERVER  
     */
    private static String driverName = "com.microsoft.sqlserver.jdbc.SQLServerDriver";  
    private static String dbUrl = "jdbc:sqlserver://localhost:1433;databaseName=    ";  
    private static String userName = "sa";
    private static String userPwd = "lalala";


    /**
     *      
     */
    public static Connection getConnection() {

        try {
            Class.forName(driverName);
            Connection conn = null;
            conn = DriverManager.getConnection(dbUrl, userName, userPwd);
            return conn;
        } catch (Exception e) {
            e.printStackTrace();
        }
        return null;
    }


    public static void createTable(String SQL) {
        Connection conn = null;
        Statement stmt = null;
        try {
            conn = getConnection();
            stmt = conn.createStatement();
            stmt.execute(SQL);
            System.out.println("----------      ----------");

        } catch (SQLException e) {
            e.printStackTrace();
            System.out.println("----------      ----------");
        } finally {
            try {
                conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }


    /**
     *   ,  ,  
     */
    public static void SaveOrUpdateOrDetete(String SQL) {
        Connection conn = null;
        Statement stmt = null;
        try {
            conn = getConnection();
            stmt = conn.createStatement();
            int rs = stmt.executeUpdate(SQL);
            if(rs > 0){
                System.out.println("----------      ----------");
            }

        } catch (SQLException e) {
            e.printStackTrace();
            System.out.println("----------      ----------");
        } finally {
            try {
                conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

    /**
     *    
     */

    public void Query(String SQL) {

        Connection conn = null;
        Statement stmt = null;
        try{
            conn = getConnection();
            stmt = conn.createStatement();
            ResultSet rs = stmt.executeQuery(SQL);
            while (rs.next()) {
                System.out.println(rs.getString("   "));
            }

        } catch (SQLException e){
            e.printStackTrace();
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            try {
                conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

    public ResultSet getResults(String SQL) {

        Connection conn = null;
        Statement stmt = null;
        try{
            conn = getConnection();
            stmt = conn.createStatement();
            ResultSet rs = stmt.executeQuery(SQL);
            return rs;

        } catch (SQLException e){
            e.printStackTrace();
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            try {
                conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        return null;
    }
}

좋은 웹페이지 즐겨찾기