Java连接sqlserver/安全套接字层SSL

妖狐艹你老母 2023-10-12 10:23 37阅读 0赞

import java.sql.Connection;
    import java.sql.DriverManager;
    import java.sql.ResultSet;
    import java.sql.SQLException;
    import java.sql.Statement;
    
    class DBjavatest {
        public static void main(String[] args) {
            String driverName = "com.microsoft.sqlserver.jdbc.SQLServerDriver";
            //连接sqlserver,驱动程序无法通过使用安全套接字层SSL加密与sqlserver建立安全连接解决方法trustServerCertificate=true
            String url = "jdbc:sqlserver://localhost:1433;DatabaseName=tsl;encrypt = true;trustServerCertificate=true";
            String userName = "sa"; 
            String userPwd = "xxxxxxx"; 
            Connection con=null;
            ResultSet rs=null;
            Statement stmt=null;
            try {
                Class.forName(driverName);
                con = DriverManager.getConnection(url, userName, userPwd);
                System.out.println("数据库连接成功！");
                //Statement 用于对数据库进行通用访问，在运行时使用静态SQL语句时很有用。 Statement接口不能接受参数。
                //在创建Statement对象后，可以使用它来执行一个SQL语句，它有三个执行方法可以执行。它们分别是 -
                // boolean execute (String SQL) ： 如果可以检索到ResultSet对象，则返回一个布尔值true; 否则返回false。使用此方法执行SQLDDL语句或需要使用真正的动态SQL，可使用于执行创建数据库，创建表的SQL语句等等。
                // int executeUpdate (String SQL): 返回受SQL语句执行影响的行数。使用此方法执行预期会影响多行的SQL语句，例如:INSERT，UPDATE或DELETE语句。
                // ResultSet executeQuery(String SQL)：返回一个ResultSet对象。 当您希望获得结果集时，请使用此方法，就像使用SELECT语句一样。
                stmt=con.createStatement();
                rs=stmt.executeQuery("SELECT TOP (10) * FROM cashxxxxx");
                System.out.println("changeinto"+"\t"+"changeout"+"\t"+"balance");
                while(rs.next())
                {
                  System.out.println(rs.getDouble(4)+"\t\t"+rs.getDouble(5)+"\t\t"+rs.getDouble(6));
                }
            } catch (ClassNotFoundException e) {
                e.printStackTrace();
            } catch (SQLException e) {
                e.printStackTrace();
            } finally{
            try{
                if(rs!=null)//若结果集不为空
                rs.close();//关闭结果集
                }catch(Exception e){
                e.printStackTrace();//异常处理
                }
            try{
                if(stmt!=null)//若Statemet对象不为空
                stmt.close();//关闭Statement对象
                }catch(Exception e){
                e.printStackTrace();//异常处理
                }
            try{
                if(con!=null)//若链接对象不为空
                con.close();//关闭链接对象
                }catch(Exception e){
                e.printStackTrace();//异常处理
                }}
        }
    }

execute、executeUpdate、executeQuery三者的区别（及返回值）
    
    1、ResultSet：executeQuery(String sql); 执行SQL查询，并返回ResultSet 对象。
    2、int：executeUpdate(String sql); 可执行增，删，改，返回执行受到影响的行数。
    3、boolean：execute(String sql); 可执行任何SQL语句，返回一个布尔值，表示是否返回ResultSet 。
    execute是executeQuery和executeUpdate的综合.
    使用哪一个方法由SQL语句所产生的内容决定
    executeUpdate() 这是 PreparedStatement 接口中的方法
    executeUpdate(String sql) 这是 PreparedStatement 从父接口 Statement 中继承过来的方法
    executeUpdate() 中执行 SQL 语句需要在创建 PerparedStatement 时通过 Connection 的 prepareStatement(String sql) 方法中写出，因为 PerparedStatement 中的 SQL 语句数据库需要进行预编译和缓存，因此要在创建 PerparedStatement 对象时给出 SQL 语句。
    而 executeUpdate(String sql) 是 Statement 中的方法，参数中的 SQL 语句只是提交给数据库去执行，并不需要预编译。
    如果 SQL 语句中有 ? 占位符，那么在设置好占位符中的值后，必须使用 executeUpdate() 执行。而 executeUpdate(String sql) 只是提交一个 SQL 语句，且这个语句中不能带有 ? 占位符。
    
    1>方法executeQuery
    用于产生单个结果集（ResultSet）的语句，例如:被执行最多的SELECT 语句。
    这个方法被用来执行 SELECT 语句，但也只能执行查询语句，执行后返回代表查询结果的ResultSet对象。例如：
        Class.forName("com.mysql.jdbc.Driver");
        //加载数据库驱动
        Connection  conn = null;
        conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/test",
                     "root","1234");
        //使用DriverManager获取数据库连接
        Statement  stmt = conn.createStatement();
        //使用Connection来创建一个Statment对象
        ResultSet rs =stmt.executeQuery("select * from teacher");
        //执行查询语句并且保存结果
        while (rs.next()){
                    System.out.println(rs.getInt(1) + "/t" +    rs.getString(2)); 
        }
        //把查询结果输出来
    
    
    
    2>方法executeUpdate
    用于执行 INSERT、UPDATE 或 DELETE 语句以及 SQL DDL（数据定义语言）语句，例如 CREATE TABLE 和 DROP TABLE。INSERT、UPDATE 或 DELETE 语句的效果是修改表中零行或多行中的一列或多列。
    executeUpdate 的返回值是一个整数（int），指示受影响的行数（即更新计数）。
    对于 CREATE TABLE 或 DROP TABLE 等不操作行的语句，executeUpdate 的返回值总为零。例如：
      Class.forName("com.mysql.jdbc.Driver");
      //加载数据库驱动
      Connection  conn = null;
      conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/test",
             "root","1234");
      //使用DriverManager获取数据库连接
      Statement  stmt = conn.createStatement();
      //使用Connection来创建一个Statment对象
      return stmt.executeUpdate(sql);
      //执行DML语句，返回受影响的记录条数
    
    
    3>方法execute：
    可用于执行任何SQL语句，返回boolean值，表明执行该SQL语句是否返回了ResultSet。
    如果执行后第一个结果是ResultSet，则返回true，否则返回false。
    但它执行SQL语句时比较麻烦，通常我们没有必要使用execute方法来执行SQL语句，而是使用executeQuery或executeUpdate更适合。
    但如果在不清楚SQL语句的类型时则只能使用execute方法来执行该SQL语句了。例如：
     Class.forName(driver);
      //加载驱动
      Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/test","root","1234");
      //获取数据库连接
      stmt = conn.createStatement();
      //使用Connection来创建一个Statment对象 
      boolean hasResultSet = stmt.execute(sql); 
      //执行SQL,返回boolean值表示是否包含ResultSet          
      if (hasResultSet) { //如果执行后有ResultSet结果集
            rs = stmt.getResultSet();
            //获取结果集 
            ResultSetMetaData rsmd = rs.getMetaData();
            //ResultSetMetaData是用于分析结果集的元数据接口 
            int  columnCount = rsmd.getColumnCount();
            while (rs.next()){//输出ResultSet对象
                 for (int i = 0 ; i < columnCount ; i++ ) {
                     System.out.print(rs.getString(i + 1) + "/t");
                 }  
                 System.out.print("/n");
            } 
       } else  {
             System.out.println("该SQL语句影响的记录有" + stmt.getUpdateCount() + "条");
      }

import java.sql.Connection;
    import java.sql.DriverManager;
    import java.sql.ResultSet;
    import java.sql.SQLException;
    import java.sql.Statement;
    
    public class MSSQLDatabaseExample {
        public static void main(String[] args) {
            String jdbcUrl = "jdbc:sqlserver://localhost:1433;DatabaseName=txx;encrypt = true;trustServerCertificate=true;";
            String username = "sa";
            String password = "xxx";
    
            try {
                // 加载MSSQL驱动程序
                Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
    
                // 建立数据库连接
                Connection connection = DriverManager.getConnection(jdbcUrl, username, password);
    
                // 创建Statement对象
                Statement statement = connection.createStatement();
    
                // 执行查询语句
                String query = "SELECT TOP (9000) * FROM cashxxx where othername LIKE 'xx%'";
                ResultSet resultSet = statement.executeQuery(query);
    
                // 处理结果集
                while (resultSet.next()) {
                    // 从结果集中获取数据
                    String tradinghours = resultSet.getString("tradinghours");
                    Double into = resultSet.getDouble("changeinto");
                    Double balanceNu = resultSet.getDouble("balance");
                    // 其他列...
    
                    // 处理数据
                    //System.out.println("Time:"+ tradinghours.trim() +" ,\t into: " + into + " ,\t balanceNu: " + balanceNu);
                    System.out.printf("Time: "+"%-24s"+"into: "+"%-12.2f"+"dbalanceNu: "+"%-12.2f\n",tradinghours.trim(),into,balanceNu);
                }
    
                // 关闭连接和释放资源
                resultSet.close();
                statement.close();
                connection.close();
                //connection=null;
                //System.out.println(connection);
            } catch (ClassNotFoundException e) {
                e.printStackTrace();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        
        }
    }