Jdbc中的statement对象用于向数据库发送SQL语句,想完成对数据库的增删改查,只需要通过这个对象向数据库发送增删改
查语句即可。
Statement对象的executeUpdate方法,用于向数据库发送增、删、改的sq|语句, executeUpdate执行完后,将会返回一个整
数(即增删改语句导致了数据库几行数据发生了变化)。
Statement.executeQuery方法用于向数据库发送查询语句,executeQuery方法返回代表查询结果的ResultSet对象。
CRUD操作-create
使用executeUpdate(String sq)方法完成数据添加操作,示例操作:
Statement st = conn.createstatement(); String sq1 = "insert into uer(...) values(....) "; int num = st.executeupdate(sq1); if (num>0){ System.out.print1n("插入成功!!!"); }
CRUD操作-delete
使用executeUpdate(String sq|)方法完成数据删除操作,示例操作:
Statement st = conn.CreateStatement(); String sq1 = "delete from user where id=1"; int num = st.executeupdate(sq1) ; if (num>0){ System.out. print1n(“删除成功! ! ! "); }
CRUD操作-update
使用executeUpdate(String sq|)方法完成数据修改操作,示例操作:
Statement st = conn.createStatement () ; string sq1 = "update user set name='' where name='"; int num = st.executeupdate(sq1); if(num>0){ System.out.print1n(“修改成功! ! ! "); }
CRUD操作-read
使用executeQuery(String sq|)方法完成数据查询操作,示例操作:
Statement st = conn.createStatement(); string sq1 = "select * fcom user where id=1"; Resultset rs = st.executeupdate(sq1); while(rs.next(){ //根据 获取列的数据类型,分别调用rs的相应方法映射到java对象中 }
代码实现
1、提取工具类
package com.lantian.lesson02.utils; import java.io.InputStream; import java.sql.*; import java.util.Properties; public class jdbcUtils { private static String driver = null; private static String url = null; private static String username = null; private static String password = null; static { try { InputStream in = jdbcUtils.class.getClassLoader().getResourceAsStream("src/db.properties"); Properties properties = new Properties(); properties.load(in); driver = properties.getProperty("driver"); url = properties.getProperty("url"); username = properties.getProperty("username"); password = properties.getProperty("password"); //1. 驱动只用加载一次 Class.forName(driver); } catch (Exception e){ e.printStackTrace(); } } //获取链接 public static Connection getConnection() throws SQLException { return DriverManager.getConnection(url, username, password); } //释放资源 public static void release(Connection connection, Statement statement, ResultSet resultSet){ if (resultSet!=null){ try { resultSet.close(); } catch (SQLException e) { e.printStackTrace(); } } if (statement!=null){ try { statement.close(); } catch (SQLException e) { e.printStackTrace(); } } if (connection!=null){ try { connection.close(); } catch (SQLException e) { e.printStackTrace(); } } } }
2、编写增删改查的方法 'executeUpdate'
3、查询