黑马视频 （ 7/12）
JDBC
JDBC
- JAVA Database Connectivity : java 数据库连接
为什么会出现JDBC:
SUN公司提供的一种数据库访问规则、规范, 由于数据库种类较多，并且java语言使用比较广泛，sun公司就提供了一种规范，让其他的数据库提供商去实现底层的访问规则。 我们的java程序只要使用sun公司提供的jdbc驱动即可
使用JDBC的基本步骤
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 工具类构建
- 资源释放工作的整合
驱动防二次注册
DriverManager.registerDriver(new com.mysql.jdbc.Driver()); // Driver 这个类里面有静态代码块，一上来就执行了，所以等同于我们注册了两次驱动。 其 // 实没这个必要的。 // 静态代码块 ---> 类加载了，就执行。 java.sql.DriverManager.registerDriver(new Driver()); 最后形成以下代码即可。 Class.forName("com.mysql.jdbc.Driver");使用properties配置文件
// 在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
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
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
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
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("更新失败"); }使用单元测试，测试代码
- 定义一个类， TestXXX , 里面定义方法 testXXX.
添加junit的支持。
右键工程 --- add Library --- Junit --- Junit4在方法的上面加上注解 ， 其实就是一个标记。
@Test public void testQuery() { ... }- 光标选中方法名字，然后右键执行单元测试。 或者是打开outline视图， 然后选择方法右键执行。
Dao模式
Data Access Object 数据访问对象
- 新建一个dao的接口， 里面声明数据库访问规则
/**
* 定义操作数据库的方法
*/
public interface UserDao {
/**
* 查询所有
*/
void findAll();
}新建一个dao的实现类，具体实现早前定义的规则
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); } } }直接使用实现
@Test public void testFindAll(){ UserDao dao = new UserDaoImpl(); dao.findAll(); }Statement安全问题
Statement执行 ，其实是拼接sql语句的。 先拼接sql语句，然后在一起执行。
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对象。
相比较以前的statement， 预先处理给定的sql语句，对其执行语法检查。 在sql语句里面使用 ? 占位符来替代后续要传递进来的变量。 后面进来的变量值，将会被看成是字符串，不会产生任何的关键字。
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
)
- create table 表名{列名 列的类型 列的约束
查看表
- 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 , price1.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
