你的位置:首页 > Java教程

[Java教程]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);    }  }