package com.fh.controller.ruitai.util;

 import java.sql.Connection;

 import java.sql.DriverManager;

 import java.sql.ResultSet;

 import java.sql.SQLException;

 import java.sql.Statement;

 //连接瑞泰餐饮前台数据库

 public class DBConnectSS {

     private static String dbURL = "192.168.186.128";

     private static String databaseName = "ssycyv8";

     private static String dbUser = "sa";

     private static String dbPassword = "88888888";

     public static Connection getConnectionForSS() {

         Connection conn = null;

         try {

             String url = "jdbc:sqlserver://" + dbURL + ";databaseName="

                     + databaseName + ";user=" + dbUser + ";password="

                     + dbPassword;// sa身份连接

             // Establish the connection.

             Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");

             conn = DriverManager.getConnection(url, dbUser, dbPassword);

         } catch (ClassNotFoundException | SQLException e) {

             e.printStackTrace();

         }

         return conn;

     }

     public static Connection getConnectionForSS(String dbURL,String databaseName,String dbUser,String dbPassword) {

         Connection conn = null;

         try {

             String url = "jdbc:sqlserver://" + dbURL + ";databaseName="

                     + databaseName + ";user=" + dbUser + ";password="

                     + dbPassword;// sa身份连接

             // Establish the connection.

             Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");

             conn = DriverManager.getConnection(url, dbUser, dbPassword);

         } catch (ClassNotFoundException | SQLException e) {

             e.printStackTrace();

         }

         return conn;

     }

     /**

      * @param dbtype    数据库类型

      * @param username    用户名

      * @param password    密码

      * @param dburl        数据库连接地址:端口

      * @param databaseName 数据库名

      * @return

      * @throws SQLException

      * @throws ClassNotFoundException

      */

     public static Connection getCon(String dbtype,String username,String password,String dburl,String databaseName) throws SQLException, ClassNotFoundException{

         System.out.print("数据库连接地址:"+"jdbc:sqlserver://"+dburl+"; DatabaseName="+databaseName+username+ password);

         if("mysql".equals(dbtype)){

             Class.forName("com.mysql.jdbc.Driver");

             return DriverManager.getConnection("jdbc:mysql://"+dburl+"/"+databaseName+"?user="+username+"&password="+password);

         }else if("oracle".equals(dbtype)){

             Class.forName("oracle.jdbc.driver.OracleDriver");

             return DriverManager.getConnection("jdbc:oracle:thin:@"+dburl+":"+databaseName, username, password);

         }else if("sqlserver".equals(dbtype)){

             Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");

             return DriverManager.getConnection("jdbc:sqlserver://"+dburl+"; DatabaseName="+databaseName, username, password);

         }else{

             return null;

         }

     }

     /**

      * @description 关闭数据库的所有连接

      * @param con

      * @param stmt

      * @param rs

      */

     public static void closeAll(Connection con, Statement stmt, ResultSet rs) {

         if (rs != null)

             try {

                 rs.close();

             } catch (Exception e) {

             }

         if (stmt != null)

             try {

                 stmt.close();

             } catch (Exception e) {

             }

         if (con != null)

             try {

                 con.close();

             } catch (Exception e) {

             }

     }

     // 测试

     public static void main(String[] args) {

         // Declare the JDBC objects.

         Connection con = null;

         Statement stmt = null;

         ResultSet rs = null;

         try {

             con = getConnectionForSS();

             String SQL = SqlConst.getOders("",null);

             System.out.println(SQL);

             stmt = con.createStatement();

             rs = stmt.executeQuery(SQL);

             int i = 1;

             while (rs.next()) {

                 i = i + 1;

                 System.out.println("个数:" + i);

                 System.out.println(rs.getString(1) + " " + rs.getString(2));

             }

         } catch (Exception e) {

             e.printStackTrace();

         } finally {

             closeAll(con, stmt, rs);

         }

     }

     public static String getDbURL() {

         return dbURL;

     }

     public static void setDbURL(String dbURL) {

         DBConnectSS.dbURL = dbURL;

     }

     public static String getDatabaseName() {

         return databaseName;

     }

     public static void setDatabaseName(String databaseName) {

         DBConnectSS.databaseName = databaseName;

     }

     public static String getDbUser() {

         return dbUser;

     }

     public static void setDbUser(String dbUser) {

         DBConnectSS.dbUser = dbUser;

     }

     public static String getDbPassword() {

         return dbPassword;

     }

     public static void setDbPassword(String dbPassword) {

         DBConnectSS.dbPassword = dbPassword;

     }

 }