Java 连接 SQL Server 数据库

Posted 2021-01-28 凭栏莫听雨落

　　//连接数据库
    public Connection getConnection(){
        //url为绝对路径
        String url="jdbc:sqlserver://127.0.0.1:1433;databaseName=student";
        //user为用户名
        String user="sa";
        //password为密码
        String password="*****";
        try {
            //加载数据库驱动
            Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
            System.out.println("数据库加载驱动成功");
            //使用DriverManager获取数据库连接
            Connection connection=DriverManager.getConnection(url, user, password);
            //数据库连接成功输出提示，返回connection接口
            if(connection!=null) {
                System.out.println("数据库连接成功");
                return connection;
            }
        }catch (Exception e) {//连接失败，输出失败原因
            System.out.println("连接失败："+e.getMessage());
        }
        return null;
    }
    //数据库插入
    public void insertRecord(Connection connection) throws SQLException {
        //要执行的数据库插入语句,里面的字符串可用？代替，适用于图形交互界面
        String sql="INSERT Course VALUES(?,?,?)";
        /**
         * Connection中的sql语句可以预编译保存在PreparedStatement对象中（如preparedStatement）
          *  当需要执行该语句时，直接调用ps，不需要重复地编译select语句，提高了效率。
         */
        PreparedStatement preparedStatement=connection.prepareStatement(sql);
        //为sql语句中的问号设置代替值
        preparedStatement.setString(1, "10021");
        preparedStatement.setString(2, "插入课程");
        preparedStatement.setString(3, null);
        /**
         *  方法executeUpdate用于执行 INSERT、UPDATE 或 DELETE 语句以及 SQL DDL（数据定义语言）语句
         *  例如 CREATE TABLE 和 DROP TABLE。
        * INSERT、UPDATE 或 DELETE 语句的效果是修改表中零行或多行中的一列或多列。
        * executeUpdate 的返回值是一个整数（int），指示受影响的行数（即更新计数）。
         * 对于 CREATE TABLE 或 DROP TABLE 等不操作行的语句，executeUpdate 的返回值总为零。
         */
        preparedStatement.executeUpdate();
        System.out.println("插入成功");
        //先打开的后关闭
        preparedStatement.close();
        connection.close();
    }
    //数据库删除
    public void deleteRecord(Connection connection) throws SQLException {
        //要执行的数据库删除语句
        String sql="DELETE FROM Course WHERE cno=‘10021‘";
        PreparedStatement preparedStatement=connection.prepareStatement(sql);
        preparedStatement.executeUpdate();
        System.out.println("删除成功");
        preparedStatement.close();
        connection.close();
    }
    //数据库修改
    public void updateTable(Connection connection) throws SQLException {
        //要执行的数据库修改语句
        String sql="UPDATE Course SET cname=‘修改课程‘ WHERE cno=‘10020‘";
        PreparedStatement preparedStatement=connection.prepareStatement(sql);
        preparedStatement.executeUpdate();
        System.out.println("修改成功");
        preparedStatement.close();
        connection.close();
    }
    //数据库查询
    public void queryData(Connection connection) throws SQLException {
        //要执行的数据库查询语句
        String sql="SELECT * FROM Course";
        PreparedStatement preparedStatement=connection.prepareStatement(sql);
        /**
         * 方法executeQuery 用于产生单个结果集（ResultSet）的语句，例如 SELECT 语句。 
         * 这个方法被用来执行 SELECT 语句，它几乎是使用最多的 SQL 语句。
         * 但也只能执行查询语句，执行后返回代表查询结果的ResultSet对象。
         */
        ResultSet resultSet=preparedStatement.executeQuery();
        /**
         * resultSet用来承接PreparedStatement对象查询到的结果，可以通过该对象中的方法来访问数据库。
         * 如代码中的循环所示，一开始rs光标停在第一行的前面（注意，并非第一行）
         * 当第一次执行rs.next()函数时，光标才会到第一行，用一个while循环就可以遍历整个表的行。
         * 而rs.getString(index)是用来返回第index列的值，是横向的。
         * 注意：第一列的index就是1，而不是0，和数组下标有所区别。
         */
        while (resultSet.next()) {
            //输出进行排版
            String cno=String.format("%-10s", resultSet.getString(1));
            String cname=String.format("%-15s	", resultSet.getString(2));
            String cbefore=String.format("%-10s", resultSet.getString(3));
            System.out.println("课程号："+cno+"课程名："+cname+"先行课："+cbefore);
        }
        //先打开的后关闭
        resultSet.close();
        preparedStatement.close();
        connection.close();
    }

注意:

1.方法executeQuery 用于产生单个结果集（ResultSet）的语句，例如 SELECT 语句。 被使用最多的执行 SQL 语句的方法。这个方法被用来执行 SELECT 语句，它几乎是使用最多的 SQL 语句。但也只能执行查询语句，执行后返回代表查询结果的ResultSet对象。

2.方法executeUpdate用于执行 INSERT、UPDATE 或 DELETE 语句以及 SQL DDL（数据定义语言）语句，例如 CREATE TABLE 和 DROP TABLE。INSERT、UPDATE 或 DELETE 语句的效果是修改表中零行或多行中的一列或多列。executeUpdate 的返回值是一个整数（int），指示受影响的行数（即更新计数）。对于 CREATE TABLE 或 DROP TABLE 等不操作行的语句，executeUpdate 的返回值总为零。

3.方法execute可用于执行任何SQL语句，返回一个boolean值，表明执行该SQL语句是否返回了ResultSet。如果执行后第一个结果是ResultSet，则返回true，否则返回false。但它执行SQL语句时比较麻烦，通常我们没有必要使用execute方法来执行SQL语句，而是使用executeQuery或executeUpdate更适合，但如果在不清楚SQL语句的类型时则只能使用execute方法来执行该SQL语句了。

4.关于Iterator主要有三个方法：hasNext()、next()、remove()

hasNext:没有指针下移操作，只是判断是否存在下一个元素

next：指针下移，返回该指针所指向的元素

remove：删除当前指针所指向的元素，一般和next方法一起用，这时候的作用就是删除next方法返回的元素。