Loading... # 黑马视频 ( 7/12) ## JDBC ---- ### JDBC * JAVA Database Connectivity : java 数据库连接 * 为什么会出现JDBC: > SUN公司提供的一种数据库访问规则、规范, 由于数据库种类较多,并且java语言使用比较广泛,sun公司就提供了一种规范,让其他的数据库提供商去实现底层的访问规则。 我们的java程序只要使用sun公司提供的jdbc驱动即可 #### 使用JDBC的基本步骤 ```java 1. 注册驱动 DriverManager.registerDriver(new com.mysql.jdbc.Driver()); 2. 建立连接 //DriverManager.getConnection("jdbc:mysql://localhost/test?user=monty&password=greatsqldb"); //2. 建立连接 参数一: 协议 + 访问的数据库 , 参数二: 用户名 , 参数三: 密码。 conn = DriverManager.getConnection("jdbc:mysql://localhost/student", "root", "root"); 3. 创建statement //3. 创建statement , 跟数据库打交道,一定需要这个对象 st = conn.createStatement(); 4. 执行sql ,得到ResultSet //4. 执行查询 , 得到结果集 String sql = "select * from t_stu"; rs = st.executeQuery(sql); 5. 遍历结果集 //5. 遍历查询每一条记录 while(rs.next()){ int id = rs.getInt("id"); String name = rs.getString("name"); int age = rs.getInt("age"); System.out.println("id="+id + "===name="+name+"==age="+age); } 6. 释放资源 if (rs != null) { try { rs.close(); } catch (SQLException sqlEx) { } // ignore rs = null; } ``` #### JDBC 工具类构建 * 资源释放工作的整合 * 驱动防二次注册 ```java DriverManager.registerDriver(new com.mysql.jdbc.Driver()); // Driver 这个类里面有静态代码块,一上来就执行了,所以等同于我们注册了两次驱动。 其 // 实没这个必要的。 // 静态代码块 ---> 类加载了,就执行。 java.sql.DriverManager.registerDriver(new Driver()); 最后形成以下代码即可。 Class.forName("com.mysql.jdbc.Driver"); ``` * 使用properties配置文件 ```java // 在src底下声明一个文件 xxx.properties ,里面的内容吐下: driverClass=com.mysql.jdbc.Driver url=jdbc:mysql://localhost/student name=root password=root // 在工具类里面,使用静态代码块,读取属性 static{ try { //1. 创建一个属性配置对象 Properties properties = new Properties(); InputStream is = new FileInputStream("jdbc.properties"); //对应文件位于工程根目录 //使用类加载器,去读取src底下的资源文件。 后面在servlet //对应文件位于src目录底下 //InputStream is = JDBCUtil.class.getClassLoader().getResourceAsStream("jdbc.properties"); //导入输入流。 properties.load(is); //读取属性 driverClass = properties.getProperty("driverClass"); url = properties.getProperty("url"); name = properties.getProperty("name"); password = properties.getProperty("password"); } catch (Exception e) { e.printStackTrace(); } } ``` #### 数据库的CRUD sql * insert ```java INSERT INTO t_stu (NAME , age) VALUES ('wangqiang',28) INSERT INTO t_stu VALUES (NULL,'wangqiang2',28) // 1. 获取连接对象 conn = JDBCUtil.getConn(); // 2. 根据连接对象,得到statement st = conn.createStatement(); //3. 执行添加 // String sql = "insert into t_stu values(null , 'aobama' , 59)"; String sql = "insert into t_stu (name,age) values ('aobama' , 59)"; //影响的行数, ,如果大于0 表明操作成功。 否则失败 int result = st.executeUpdate(sql); if(result >0 ){ System.out.println("添加成功"); }else{ System.out.println("添加失败"); } ``` * delete ```java DELETE FROM t_stu WHERE id = 6 // 1. 获取连接对象 conn = JDBCUtil.getConn(); // 2. 根据连接对象,得到statement st = conn.createStatement(); //3. 执行添加 String sql = "delete from t_stu where name='aobama'"; //影响的行数, ,如果大于0 表明操作成功。 否则失败 int result = st.executeUpdate(sql); if(result >0 ){ System.out.println("删除成功"); }else{ System.out.println("删除失败"); } ``` * query ```java SELECT * FROM t_stu // 1. 获取连接对象 conn = JDBCUtil.getConn(); // 2. 根据连接对象,得到statement st = conn.createStatement(); // 3. 执行sql语句,返回ResultSet String sql = "select * from t_stu"; rs = st.executeQuery(sql); // 4. 遍历结果集 while (rs.next()) { String name = rs.getString("name"); int age = rs.getInt("age"); System.out.println(name + " " + age); } ``` * update ```java UPDATE t_stu SET age = 38 WHERE id = 1; // 1. 获取连接对象 conn = JDBCUtil.getConn(); // 2. 根据连接对象,得到statement st = conn.createStatement(); //3. 执行添加 String sql = "update t_stu set age = 26 where name ='qyq'"; //影响的行数, ,如果大于0 表明操作成功。 否则失败 int result = st.executeUpdate(sql); if(result >0 ){ System.out.println("更新成功"); }else{ System.out.println("更新失败"); } ``` #### 使用单元测试,测试代码 1. 定义一个类, TestXXX , 里面定义方法 testXXX. 2. 添加junit的支持。 右键工程 --- add Library --- Junit --- Junit4 3. 在方法的上面加上注解 , 其实就是一个标记。 ```java @Test public void testQuery() { ... } ``` 4. 光标选中方法名字,然后右键执行单元测试。 或者是打开outline视图, 然后选择方法右键执行。 #### Dao模式 > Data Access Object 数据访问对象 1. 新建一个dao的接口, 里面声明数据库访问规则 ```java /** * 定义操作数据库的方法 */ public interface UserDao { /** * 查询所有 */ void findAll(); } ``` 2. 新建一个dao的实现类,具体实现早前定义的规则 ```java public class UserDaoImpl implements UserDao{ @Override public void findAll() { Connection conn = null; Statement st = null; ResultSet rs = null; try { //1. 获取连接对象 conn = JDBCUtil.getConn(); //2. 创建statement对象 st = conn.createStatement(); String sql = "select * from t_user"; rs = st.executeQuery(sql); while(rs.next()){ String userName = rs.getString("username"); String password = rs.getString("password"); System.out.println(userName+"="+password); } } catch (Exception e) { e.printStackTrace(); }finally { JDBCUtil.release(conn, st, rs); } } } ``` 3. 直接使用实现 ```java @Test public void testFindAll(){ UserDao dao = new UserDaoImpl(); dao.findAll(); } ``` #### Statement安全问题 1. Statement执行 ,其实是拼接sql语句的。 先拼接sql语句,然后在一起执行。 ```java String sql = "select * from t_user where username='"+ username +"' and password='"+ password +"'"; UserDao dao = new UserDaoImpl(); dao.login("admin", "100234khsdf88' or '1=1"); /* SELECT * FROM t_user WHERE username='admin' AND PASSWORD='100234khsdf88' or '1=1' */ //前面先拼接sql语句, 如果变量里面带有了 数据库的关键字,那么一并认为是关键字。 不认为是普通的字符串。 rs = st.executeQuery(sql); ``` #### PrepareStatement > 该对象就是替换前面的statement对象。 1. 相比较以前的statement, 预先处理给定的sql语句,对其执行语法检查。 在sql语句里面使用 ? 占位符来替代后续要传递进来的变量。 后面进来的变量值,将会被看成是字符串,不会产生任何的关键字。 ```java String sql = "insert into t_user values(null , ? , ?)"; ps = conn.prepareStatement(sql); //给占位符赋值 从左到右数过来,1 代表第一个问号, 永远你是1开始。 ps.setString(1, userName); ps.setString(2, password); ``` ### 数据库 ----------- ##### 常见的关系数据库 * mysql : 开源的免费的适用于中小型企业的免费数据库,sun公司收购了 mysql , oracle 收购了 sun 公司, 但是oracle 收购后开始收费了,mysql * mariadb : 由 mysql 创始人做出来的,是 mysql 开源版本的一个分支,基本上所有的命令和 mysql 都是一样的 * oracle ,甲骨文公司,商业软件,收费软件,适用于大型电商网站,收购了 sun 公司,所以 java 也属于 oracle * db2 :IBM 公司, ThinkPad ,提供解决方案,软件和硬件,服务器架构,银行系统大多数采用的是 db2 , * sqlserver :政府网站,asp.net ,大学一般都是 SQLServer ,因为图形化工具做的不错 * sybase: 被淘汰的数据库 ##### NOSQL 非关系型数据库 : key : value * MongoDB * Redis ##### 关系数据库 * 主要是用来描述实体与实体之间的关系的。 * E-R 关系图, Entity Relations Disgram , * 矩形表示实体 * 菱形表示联系 * 椭圆形表示属性 ##### MySQL 数据库服务器 * mysql 数据库:数据库管理软件 * 服务器: 就是一台电脑,这台电脑安装相关的服务器软件买这些软件监听不同的端口号,根据用户访问的端口号,提供不同的服务。 ##### SQL * SQL: Structure Query Language 结构化查询语言 * DDL: 数据定义语言,定义数据库,数据表的结构等 * create 创建 * drop 删除 * alter 修改 * DML : 数据操作语言 * insert 插入 * update 更新 * delete 删除 * DCL : 数据控制语言,定义访问权限,取消访问权限,安全设置。 grant * DQL : 数据查询语言: * select 查询 * from 子句 * where 子句 ##### mysql数据库服务器使用 * 登录: mysql -uroot -p111 * 创建数据库: * create database 数据库的名字 ; * create datebase day06 character set utf8; ( 设置字符编码 ) * create database day06_1 character set utf8 collate utf8_bin; 确定校对规则 * 查看数据库: * show databases; 查看所有的数据库 * show create database day06; 查看数据库的定义 * 修改数据库 * alter database day06 character set gbk; 修改数据库字符集编码 * 删除数据库 * drop database day06; * 切换数据库 * use day06; * 查看当前正在使用的数据库: * select database(); ##### 表 * 创建表: * create table 表名{列名 列的类型 列的约束 列名2 列的类型 列的约束 } * 列的约束: * 主键约束 : primary key * 唯一约束: unique * 非空约束:not null * create table student( sid int primary key , sname vachar(31), sex int , age int ) * 查看表 * show tables ; 查看所有表 * show create table 表名; 查看表的定义,创建过程 * desc 表名; 查看表的结构 * 修改表 * 添加列 add : alter table 表名 add 列名 列的类型 列的约束 * alter table student add chengji int not null ; * 修改列 modify : alter table student modify sex varchar( 2 ) ; * 修改列名 change : alter table student change sex gender varchar( 2 ) ; * 删除列 drop : alter table student drop chengji ; * 修改表名 rename : rename table student to student1 * 修改表的字符集:alter table student1 character set gbk ; * 删除表 * drop table student1 ; 删除表 ##### SQL完成对表中数据的 CURD * 插入数据 * insert into 表名 ( 列名1,列名2,列名3 ) values (1,2,3) ; * insert into studednt ( sid,sname,sex,sage ) value ( 1,"xx",1,23 ) ; * insert into studednt value ( 2,"xx",1,23 ) ; //如果插入的是部分列,不可以省略 * 批量插入 * insert into studednt value ( 9,"xx",1,23 ) ,( 7,"xx",1,23 ),( 5,"xx",1,23 ),( 3,"xx",1,23 ) ; * 批量插入效率高于单条插入 * 修改 my.ini ,文件中的编码方式修改。(中文乱码) * 查看表中数据 * select * from 表名 * 删除记录 * ddelete from 表名 [where 条件] * delete from student where sid = 2 ; * delete from student ; 没有指定条件,会将数据全部删除 * delete : DML,一条一条的从表中删除数据 * truncate: DDL,先删除表再重建表 * 关于那条语句执行效率高,要看表中具体的数据量, * 数据比较少,delete 比较高效 * 数据比较多,truncate 比较高效 * 更新记录 * update 表名 set 列名=列的值,列名2=列的值 [where 条件] ;(如果参数是字符串或者日期要加上单引号,不加where 条件,更新的是所有数据) * update student set sname='lisi' where sid=5; * 查询记录 select [ distinct ] [ * ] [ 列名,列名2 ] from 表名 [ where 条件 ] ; ( distinct 去除重复数据 ) * 表的别名: select p.pname,p.price from product as p ; ( as 关键字可以省略 ) * 列的别名 : select pname as 商品名称 , price as 商品价格 from product ; * 去掉重复的值:select distinct price from product ; * 运算查询: sekect * , price*1.5 as 折后价格 from product ;( 在查询出的结果上做了操作 ,数据库中并没有做改变 ) * 关系运算符: * <> : 不等于 :标准的 SQL 语法 * != : 不等于:非标准的 SQL 语法 * select * from product where proce > 10 and price < 10 * select * from product where price between 10 and 100 ; * select * from product where price < 35 or price > 100 ; * 模糊查询 * _ :代表一个字符 * %:代表多个字符 * is null : 判断是否为空 * select * from prodcut where pname like '_x%' ; * in 在某个范围内获得值 * select * from product where cno in (1,4,5) ; * 排序查询:order by * asc : ascend 升序 ( 默认使用这个排序 ) * desc : descend 降序 * select * from product where pname like '%小%' order by price asc ; * 聚合函数: * sum() :求和 * avg() :平均值 * count() :统计数量 * max() :最大值 * min() :最小值 * select sum ( price ) from product ; * select count ( * ) from product ; * where 条件后面不能跟聚合函数 * select * from product where price > ( select avg( price ) from product ) ;嵌套查询 * group by 分组 * select cno,count ( * ) from product group by cno ; * having : 可以链接聚合函数 ,出现在分组之后 * where : 不可以接聚合函数,出现在分组之前 * select cno,avg( price ) from product group by cno having avg( price ) > 60 ; * 编写顺序: * S..F..W..G..H..O * select ... from ... where ... group by ... having ... order by * 执行顺序: * F...W..G..H..S..O * from ... where...group by ...having .... select .... order by 最后修改:2018 年 07 月 29 日 © 允许规范转载 打赏 赞赏作者 支付宝微信 赞 哇卡哇卡