java学习笔记—JDBC2（17）

1、复习：jdbc的六个固定步骤*(以查询为例)

        //1.将驱动进行注册(可以进行与数据库的链接)                DriverManager.registerDriver(new Driver());                //2.得到一个与数据库连接的对象        Connection con=DriverManager.getConnection("jdbc:MySQL://127.0.0.1:3306/mydb","root","root");                //3.得到一个执行sql对象        Statement st=con.createStatement();        //4.执行sql语句. 以查询为例,执行后会返回一个ResultSet结果集。(其实就是包含查询到的信息)        ResultSet rs=st.executeQuery("sql_select语句");                //5.将结果集中的内容迭代出来.                while(rs.next()){                rs.getObject("字段名称");            }                            //6.需要将资源释放                    xxx.close();

2、jdbc的CRUD操作

新建一个CRUDTest 测试类

执行 select 时所使用的方法是 executeQuery

执行 insert delete update 时用到的方法是 executeUpdate

以下方法中用到的jdbcUtil类，请看上一篇

2.1 查询

// @Test    public void select() {        Connection con = null;        Statement st = null;        ResultSet rs = null;        try {            con = JdbcUtil.getConnection();            st = con.createStatement();            rs = st.executeQuery("select * from emp");            while (rs.next()) {                //输出第二列                System.out.PRintln(rs.getInt(1));            }        } catch (SQLException e) {            e.printStackTrace();        } finally {            //关闭            JdbcUtil.close(rs);            JdbcUtil.close(st);            JdbcUtil.close(con);        }    }

2.2 添加

@Test    public void add() {        // 向Users表中添加信息 name=james        // 定义的要执行的sql语句        String sql = "insert into users(id,name) values(2,'fox')";        // 获得连接        Connection con = JdbcUtil.getConnection();        Statement st = null;        try {            st = con.createStatement();            // 使用executeUpdate            int row = st.executeUpdate(sql);            // 通过row是否为0 判断操作是否成功            if (row == 0) {                System.out.println("add 失败");            } else {                System.out.println("add成功");            }        } catch (SQLException e) {            e.printStackTrace();        } finally {            JdbcUtil.close(st);            JdbcUtil.close(con);        }    }

2.3 修改

@Test    public void update() {        String sql = "update users set name='tony' where id=2";        // 获得连接        Connection con = JdbcUtil.getConnection();        Statement st = null;        try {            st = con.createStatement();            // 重点 使用executeUpdate            int row = st.executeUpdate(sql);            // 通过row是否为0 判断操作是否成功            if (row == 0) {                System.out.println("update失败");            } else {                System.out.println("update成功");            }        } catch (SQLException e) {            e.printStackTrace();        } finally {            JdbcUtil.close(st);            JdbcUtil.close(con);        }    }

2.4 删除

@Test    public void delete() {        String sql = "delete from users where id=2";        // 获得连接        Connection con = JdbcUtil.getConnection();        Statement st = null;        try {            st = con.createStatement();            // 重点 使用executeUpdate            int row = st.executeUpdate(sql);            // 通过row是否为0 判断操作是否成功            if (row == 0) {                System.out.println("删除 失败");            } else {                System.out.println("删除成功");            }        } catch (SQLException e) {            e.printStackTrace();        } finally {            JdbcUtil.close(st);            JdbcUtil.close(con);        }    }