快速上手JDBC
目录
1.PreparedStatement 与 Statement
一、步骤
1.导入所需数据库的jar包,(这里以mysql为例)
2.获取连接
3.连接后进行CRUD操作
二、ORM思想
ORM思想(Object relational mapping)
● 一个数据表对应一个java类
● 表中的一条记录对应java类的一个对象
● 表中的一个字段对应java类的一个属性
三、如何获取连接
1.Driver接口实现类
♣ java.sql.Driver 接口是所有 JDBC 驱动程序需要实现的接口。这个接口是提供给数据库厂商使用的,不同数据库厂商提供不同的实现。
♣ 在程序中不需要直接去访问实现了 Driver 接口的类,而是由驱动程序管理器类(java.sql.DriverManager)去调用这些Driver实现。
2.URL
♣ JDBC URL 用于标识一个被注册的驱动程序,驱动程序管理器通过这个 URL 选择正确的驱动程序,从而建立到数据库的连接。
♣ JDBC URL的标准由三部分组成,各部分间用冒号分隔。
●jdbc:子协议:子名称
●协议:JDBC URL中的协议总是jdbc
●子协议:子协议用于标识一个数据库驱动程序
●子名称:一种标识数据库的方法。子名称可以依不同的子协议而变化,用子名称的目的是为 了定位数据库提供足够的信息。包含主机名(对应服务端的ip地址),端口号,数据库名
3.用户名和密码
♣ user,password可以用“属性名=属性值”方式告诉数据库
♣ 可以调用 DriverManager 类的 getConnection() 方法建立到数据库的连接
4.代码示例
public void testConnection5() throws Exception { //1.加载配置文件 InputStream is = ConnectionTest.class.getClassLoader().getResourceAsStream("jdbc.properties"); Properties pros = new Properties(); pros.load(is); //2.读取配置信息 String user = pros.getProperty("user"); String password = pros.getProperty("password"); String url = pros.getProperty("url"); String driverClass = pros.getProperty("driverClass"); //3.加载驱动 Class.forName(driverClass); //Driver driver = (Driver) clazz.newInstance(); //DriverManager.registerDriver(driver); /* 可以注释掉上述代码的原因,是因为在mysql的Driver类中声明有: static { try { DriverManager.registerDriver(new Driver()); } catch (SQLException var1) { throw new RuntimeException("Can't register driver!"); } } */ //4.获取连接 Connection conn = DriverManager.getConnection(url,user,password); System.out.println(conn); }
其中配置文件声明在工程的src目录下 名为【jdbc.properties]】 的文本文件下
user=root
password=abc123
url=jdbc:mysql://localhost:3306/test
driverClass=com.mysql.jdbc.Driver
四、如何实现CRUD操作
1.PreparedStatement 与 Statement
PreparedStatement 介绍:
♣ 可以通过调用 Connection 对象的preparedStatement(String sql) 方法获取 PreparedStatement 对象
♣ PreparedStatement 接口是 Statement 的子接口,它表示一条预编译过的 SQL 语句
♣PreparedStatement 对象所代表的 SQL 语句中的参数用问号(?)来表示,调用 PreparedStatement 对象的 setXxx() 方法来设置这些参数. setXxx() 方法有两个参数,第一个参数是要设置的 SQL 语句中的参数的索引(从 1 开始),第二个是设置的 SQL 语句中的参数的值
Statement弊端:
♣ 存在拼串操作、繁琐
♣ 存在sql注入问题
2.ResultSet与ResultSetMetaData
ResultSet介绍:
♣ 查询需要调用PreparedStatement 的 executeQuery() 方法,查询结果是一个ResultSet 对象
♣ ResultSet 对象以逻辑表格的形式封装了执行数据库操作的结果集,ResultSet 接口由数据库厂商提供实现
♣ ResultSet 返回的实际上就是一张数据表。有一个指针指向数据表的第一条记录的前面。
♣ ResultSet 对象维护了一个指向当前数据行的**游标**,初始的时候,游标在第一行之前,可以通过 ResultSet 对象的 next() 方法移动到下一行。调用 next()方法检测下一行是否有效。若有效,该方法返回 true,且指针下移。相当于Iterator对象的 hasNext() 和 next() 方法的结合体。
♣ 当指针指向一行时, 可以通过调用 getXxx(int index) 或 getXxx(int columnName) 获取每一列的值。
ResultSetMetaData介绍:
♣ (通过ResultSet的getMetaData()获得)
♣ 可用于获取关于 ResultSet 对象中列的类型和属性信息的对象
♣ ResultSetMetaData meta = rs.getMetaData();
ResultSetMetaData方法:
♣ getColumnName(int column):获取指定列的名称 (基本不用)
♣ getColumnLabel(int column):获取指定列的别名
♣ getColumnCount():返回当前 ResultSet 对象中的列数
♣ getColumnTypeName(int column):检索指定列的数据库特定的类型名称。
♣ getColumnDisplaySize(int column):指示指定列的最大标准宽度,以字符为单位。
♣ isNullable**(int column):指示指定列中的值是否可以为 null。
♣ isAutoIncrement(int column):指示是否自动为指定列进行编号,这样这些列仍然是只读的。
3.增删改代码示例(通用)
//通用的增、删、改操作(体现一:增、删、改 ; 体现二:针对于不同的表) public void update(String sql,Object ... args){ Connection conn = null; PreparedStatement ps = null; try { //1.获取数据库的连接 conn = JDBCUtils.getConnection();//连接已封装在方法中 //2.获取PreparedStatement的实例 (或:预编译sql语句) ps = conn.prepareStatement(sql); //3.填充占位符 for(int i = 0;i < args.length;i++){ ps.setObject(i + 1, args[i]); } //4.执行sql语句 ps.execute(); } catch (Exception e) { e.printStackTrace(); }finally{ //5.关闭资源 JDBCUtils.closeResource(conn, ps);//资源关闭已封装在方法中 } }
4.查询代码示例(通用)
// 通用的针对于不同表的查询:返回一个对象 (version 1.0) public <T> T getInstance(Class<T> clazz, String sql, Object... args) { Connection conn = null; PreparedStatement ps = null; ResultSet rs = null; try { // 1.获取数据库连接 conn = JDBCUtils.getConnection(); // 2.预编译sql语句,得到PreparedStatement对象 ps = conn.prepareStatement(sql); // 3.填充占位符 for (int i = 0; i < args.length; i++) { ps.setObject(i + 1, args[i]); } // 4.执行executeQuery(),得到结果集:ResultSet rs = ps.executeQuery(); // 5.得到结果集的元数据:ResultSetMetaData ResultSetMetaData rsmd = rs.getMetaData(); // 6.1通过ResultSetMetaData得到columnCount,columnLabel;通过ResultSet得到列值 int columnCount = rsmd.getColumnCount(); if (rs.next()) { T t = clazz.newInstance(); for (int i = 0; i < columnCount; i++) {// 遍历每一个列 // 获取列值 Object columnVal = rs.getObject(i + 1); // 获取列的别名:列的别名,使用类的属性名充当 String columnLabel = rsmd.getColumnLabel(i + 1); // 6.2使用反射,给对象的相应属性赋值 Field field = clazz.getDeclaredField(columnLabel); field.setAccessible(true); field.set(t, columnVal); } return t; } } catch (Exception e) { e.printStackTrace(); } finally { // 7.关闭资源 JDBCUtils.closeResource(conn, ps, rs); } return null; }