java学习笔记—JDBC2（17）

浏览数：13 / 时间：2015年06月12日

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);
        }
    }