/*
授权命令 grant 权限 to 用户
授权可以授予多个权限
grant connect,resource to baidu
收回权限 revoke 权限 from 用户
revoke dba from baidu
创建用户 分配表空间--指定用户的默认表空间
create table p(..) 建表存在默认表空间
--建表时候指定表空间
create table p(...) talebspace 表空间名
*/
/*
plsql编程语言 procedure language 过程语言
是在sql语句中加入一些处理过程的语句
常见的条件表达式 if else 还有循环结构
基本结构
declare
--声明部分 理解为定义
--声明使用的变量
begin
--处理逻辑的代码块
end;
*/
--pssql简单示例
declare
v_n number := 1; --声明数值变量 赋值使用符号:=
v_s varchar2(4) :='s'; --声明字符类型变量
emp_ename emp.ename%type ;-- 引用类型变量
emp_row emp%rowtype ;-- 记录类型变量
begin
dbms_output.put_line('v_n====='||v_n); --输出语句相当于sys out
dbms_output.put_line('v_s====='||v_s);
select ename into emp_ename from emp where empno=7499; --使用into关键字赋值
dbms_output.put_line('emp_ename====='||emp_ename);
select * into emp_row from emp where empno = 7499; --赋值记录类型变量
dbms_output.put_line('员工编号=='||emp_row.empno||'员工姓名'||emp_row.ename);
end;
/*
plsql 的条件表达式判断
if .. 处理语句 else if ..处理语句
-------------------------
if .. then
elsif .. then
else
end if;
*/
---使用条件表达式判断员工的工资 使用汉字输出
declare
emp_row emp%rowtype ;-- 记录类型变量
begin
select * into emp_row from emp where empno = 7499; --赋值记录类型变量
--使用表达式判断工资
if emp_row.sal > 3000 then
dbms_output.put_line('员工工资大于3000=='||emp_row.sal);
elsif emp_row.sal < 1000 then
dbms_output.put_line('员工工资小于1000=='||emp_row.sal);
else
dbms_output.put_line('员工工资位于1000到3000之间=='||emp_row.sal);
end if;
end;
/*
循环结构
第一种-----
loop
exit when 条件
end loop;
第二种 ---
while 条件 loop
end loop;
第三种 ---
for 变量 in 范围 loop
end loop;
*/
-------使用循环输出数字 1-----10
/*
第一种
loop
exit when 条件
end loop;
*/
declare
v_n number :=1;
begin
loop
--只是用来判断退出使用的,并不是相当于if()else{}
exit when v_n>10 ; --退出条件
dbms_output.put_line(v_n);
v_n:=v_n+1; --自增
end loop;
end;
/*
第二种
while 条件 loop
end loop;
*/
declare
v_n number :=1;
begin
while v_n<11 loop
dbms_output.put_line(v_n);
v_n:=v_n+1; --自增
end loop;
end;
/*
第三种
for 变量 in 范围 loop 变量的声明和范围的控制是由for循环自动执行
end loop;
*/
declare
begin
for i in 1..10 loop
dbms_output.put_line(i);
end loop;
end;
/*
游标 光标 是用于接收查询的记录结果集 resultset 提示记录使用.next()
游标的使用步骤
声明游标 cursor 游标名 is select 语句 指定游标的记录结果集
打开游标 open 游标名
提取游标 fetch 游标名 into 记录类型变量
关闭游标 close cursor
游标的两个属性 游标名%found : 判断它有找到
游标名%notfound : 判断它没有找到
if emp_cursor%found then
dbms_output.put_line('found');
elsif emp_cursor%notfound then
dbms_output.put_line('notfound');
elsif emp_cursor%notfound is null then
dbms_output.put_line('null');
end if;
*/
--使用while循环结构演示游标
declare
--声明游标
cursor emp_cursor is select * from emp;
--声明记录类型变量 用于接收游标提取的记录
emp_row emp%rowtype;
begin
--打开游标
open emp_cursor;
--提取游标(判断下一个是否有值)
fetch emp_cursor into emp_row ;
--有值就执行while循环
while emp_cursor%found loop
dbms_output.put_line(emp_row.empno||'员工姓名'||emp_row.ename);
--继续提取游标(并判断下一个是否有值)
fetch emp_cursor into emp_row ;
end loop;
close emp_cursor;
end;
/*
loop
exit when 游标提取不到
end loop
*/
declare
--声明游标
cursor emp_cursor is select * from emp;
--声明记录类型变量 用于接收游标提取的记录
emp_row emp%rowtype;
begin
--打开游标
open emp_cursor;
loop
fetch emp_cursor into emp_row;
exit when emp_cursor%notfound;
dbms_output.put_line(emp_row.empno||'员工姓名'||emp_row.ename);
end loop;
close emp_cursor;
end;
--使用游标提取某个部门的员工信息
--声明带参数的游标信息
declare
--声明游标
cursor emp_cursor(dno number) is select * from emp where deptno = dno ;
--声明记录类型变量 用于接收游标提取的记录
emp_row emp%rowtype;
begin
--打开游标 时候传入参数
open emp_cursor(10);
loop
fetch emp_cursor into emp_row;
exit when emp_cursor%notfound;
dbms_output.put_line(emp_row.empno||'员工姓名'||emp_row.ename);
end loop;
close emp_cursor;
end;
/*
错误信息开发中的异常
数据库中叫做 例外
异常的分类 1.系统异常 系统定义好的异常
2.自定义的异常
new 自定义类继承exception 自定义传值（错误代码，提示信息）
使用场景
不满足某些特定业务场景，抛出自定义异常
异常的处理
java try{}catche(indexoutofboundexception e){}catche(exception e){}
java try{}catche(exception e){} catche(indexoutofboundexception e){}--报错
数据库可以捕捉处理异常
exception 关键字捕捉异常
when 异常类型 then 处理语句 判断异常类型 处理异常
*/
--异常的简单示例
/*
--除0的异常 除数为0
--赋值错误
*/
declare
v_n number :=0;
v_m number :=1;
begin
v_m:='s'; --将字符串赋值给数值变量
v_m:= v_m/v_n;
exception
when zero_divide then
dbms_output.put_line('除数不能为0');
when value_error then
dbms_output.put_line('赋值有误');
end;
---处理太多记录数异常
declare
emp_row emp%rowtype ;-- 记录类型变量
begin
select * into emp_row from emp ; --赋值记录类型
exception
when too_many_rows then
dbms_output.put_line('太多记录数');
when others then --others是最大范围的异常 相当于java 的 exception
dbms_output.put_line('其他异常');
end;
/*
需求 ：使用游标查询部门下的员工信息
如果部门下没有员工 报错提示
需要自定义异常
变量名 exception --声明自定义异常
*/
declare
cursor emp_cursor is select * from emp where deptno= 40; --游标结果集不存在
emp_row emp%rowtype ;-- 记录类型变量
no_dept_emp exception ; --声明自定义异常
begin
open emp_cursor; --打开游标
fetch emp_cursor into emp_row;
if emp_cursor%notfound then
--没有员工 抛出错误异常
raise no_dept_emp;
end if;
close emp_cursor;
exception
when no_dept_emp then
dbms_output.put_line('部门下面没人，快招人吧');
end;
/*
存储过程 是一段封装好的代码块，过程是编译好放在服务器提供开发人员调用
封装的代码块意义： 提升开发效率 可以复用 谁用直接调用
提升运行效率 一调用直接运行
语法：create [or repalce] procedure 过程名称(参数名 out|in 参数类型)
as|is
--声明变量的部分
begin
--处理过程语句代码块
end;
调用存储过程
在begin和end之间使用 过程名传参调用
*/
--存储过程的简单示例 使用存储过程给某个员工增加工资100
create or replace procedure add_sal(eno in number )
as
emp_sal number :=0;
begin
select sal into emp_sal from emp where empno = eno ;
dbms_output.put_line('涨工资之前是===='||emp_sal);
update emp set sal=sal+100 where empno = eno;
select sal into emp_sal from emp where empno = eno ;
dbms_output.put_line('涨工资之后是===='||emp_sal);
commit;
end;
--------调用存储过程
declare
begin
add_sal(7499);
end;
/*
使用存储过程统计某个员工的年薪，年薪需要返回输出打印
in 类型输入参数可以 省略 默认就是输入参数
*/
create or replace procedure count_sal(eno number,year_sal out number)
as
begin
select sal*12+nvl(comm,0) into year_sal from emp where empno=eno; --使用into赋值给输出参数
end;
----调用存储过程计算年薪
declare
v_emp_sal number :=0;
begin
count_sal(7499,v_emp_sal);
dbms_output.put_line('年薪为=='||v_emp_sal);
end;
/*
使用存储过程 查询出某个部门的员工信息
某个部门应该接受一个in类型的输入参数
查询到的部门员工多条记录返回应该使用结果集
声明游标 cursor 游标名 is select 语句指定结果集
系统引用游标
sys_refcursor
声明系统引用游标 变量名 sys_refcursor; --不需要指定结果集
打开游标 open 系统引用游标 for select 语句 --使用for关键字装入数据
*/
create or replace procedure dept_emp(dno number,cusor_emp out sys_refcursor)
as
begin
--根据传进来的部门编号给游标装入结果集数据
open cusor_emp for select * from emp where deptno = dno;
end;
----调用存储过程查询部门下的员工
declare
cursor_emp sys_refcursor; --声明系统引用游标传参使用
emp_row emp%rowtype ;--记录类型变量
begin
dept_emp(10,cursor_emp);
--提取游标中的数据
loop
fetch cursor_emp into emp_row;
exit when cursor_emp%notfound;
dbms_output.put_line('编号'||emp_row.empno||'姓名'||emp_row.ename);
end loop;
close cursor_emp;
end;
/*
存储函数 是一段封装好的代码块，是编译好放在服务器提供开发人员调用
封装的代码块意义： 提升开发效率 可以复用 谁用直接调用
提升运行效率 一调用直接运行
语法：create [or repalce] function 函数名称(参数名 out|in 参数类型) return 数据类型
in 代表传入参数,out 代表传出参数
as|is
--声明变量的部分
begin
--处理过程语句代码块
--return 变量
end;
调用存储函数
在begin和end之间使用 函数名传参调用 函数必须使用变量接收 返回值
*/
--使用存储函数统计某个员工的年薪
create or replace function count_emp_sal(eno number,year_sal out number) return number
as
v_sal number :=0;
begin
select sal*12+nvl(comm,0) into year_sal from emp where empno=eno; --使用into赋值给输出参数
return v_sal;
end;
--不带out类型输出参数统计年薪
create or replace function count_sal_noout(eno number) return number
as
v_sal number :=0;
begin
select sal*12+nvl(comm,0) into v_sal from emp where empno=eno; --使用into赋值给输出参数
return v_sal;
end;
--调用函数统计年薪
declare
emp_sal number:=0;
total_sal number :=0;
begin
--total_sal := count_emp_sal(7499,emp_sal);
total_sal := count_sal_noout(7499);
dbms_output.put_line(emp_sal);--0
dbms_output.put_line(total_sal); --统计后年薪
end;
/*
存储函数和过程的区别
1.创建的关键字 procedure funciton
2.创建函数 必须使用return 声明函数的返回变量数据类型
3.在函数的方法体内 必须使用return 返回一个变量
4.函数的调用 必须有变量接收返回值
5.函数可以用在select 查询语句中 select emp.*,count_sal_noout(empno) from emp;
存储函数和过程使用场景
开发规范 java代码待用过程 过程是用来处理业务逻辑代码
如果逻辑中需要用到一些功能性的封装，可以调用函数
90%情况下 函数和过程通用 过程可以调用函数，函数同样可以调用过程
*/
/*
触发器 是一个监视器，监视对表中数据的操作
如果对数据的操作满足触发器的执行条件，
触发器会自动运行
触发器语法：
create or repalce trigger 触发器名称
after|before --触发器执行时机
insert|update|delete --监视的动作
on 表名 --表级触发器
declare
begin
end;
行级触发器 insert update delete
:new 动作之后的记录 要插入的记录 修改后的记录 空
:old 动作之前的记录 空 原始的记录 原始的记录
*/
--创建触发器监视表，如果表中有数据插入，输出一个欢迎语句
create or replace trigger insert_trigger
after
insert
on p
declare
begin
dbms_output.put_line('欢迎加入！');
end;
----插入数据测试效果
insert into p values(1,'zs');
commit;
--插入数据不能在休息日插入数据
--休息日 周六和周日
/*
raise_application_error(v1,v2) v1错误代码 v2是提示语句
-20000 -20999
*/
create or replace trigger insert_no_work
before
insert
on p
declare
v_day varchar2(10) ;
begin
--获取到当前星期
select to_char(sysdate,'day') into v_day from dual;
--判断星期是否在休息日
if trim(v_day) in ('saturday','sunday') then
--如果休息 错误提示
raise_application_error(-20001,'不能休息日插入数据');
end if;
end;
----插入数据测试效果
insert into p values(1,'zs');
commit;
--使用触发器监视表中数据修改，不能做降低工资的操作
create or replace trigger can_not_low
before
update
on emp
for each row --行级触发器
declare
begin
--获取到原始记录的工资 --获取修改后的工资
if :old.sal > :new.sal then
--谈错误框提示
raise_application_error(-20002,'不能降低工资');
end if;
end;
--修改员工的工资测试触发器
update emp set sal=sal-1 where empno=7499;
/*
触发器实际应用
使用触发器实现 插入数据的id 自增长 面试题
**/
create or replace trigger auto_increment_id
before
insert
on test_trigger
for each row
declare
begin
--补全将要插入记录的id
--补全的id 是自增长的数值 如果没有提前创建序列,需要提前创建序列 --创建序列 create sequence order_sequence
select order_sequence.nextval into :new.pid from dual;
end;
insert into test_trigger(pname,phone) values('zs','1234566');
commit;
package baidu;
import java.sql.callablestatement;
import java.sql.connection;
import java.sql.drivermanager;
import java.sql.preparedstatement;
import java.sql.resultset;
import org.junit.test;
import oracle.jdbc.oraclecallablestatement;
import oracle.jdbc.oracletypes;
public class testjdbc {
string driverclass = "oracle.jdbc.driver.oracledriver";
string url ="jdbc:oracle:thin:@192.168.17.128:1521:orcl";
string user= "baidu_03";
string password = "baidu_03";
/*
*测试jdbc连接数据库
*
* */
@test
public void queremp(){
try{
//加载驱动
class.forname(driverclass);
//获取链接
connection con = drivermanager.getconnection(url, user,password);
//获取预编译的statement
preparedstatement pst= con.preparestatement("select * from emp");
//执行查询
resultset rs = pst.executequery();
//处理结果
while(rs.next()){
system.out.println(rs.getint(1)+"员工姓名"+rs.getstring("ename"));
}
rs.close();
con.close();
//关闭连接
}catch(exception e){
e.printstacktrace();
}
}
/*存储过程的调用
* {call <procedure-name>[(<arg1>,<arg2>, ...)]}
add_sal(eno number,addsal number)
* */
@test
public void calladdsal(){
try{
//加载驱动
class.forname(driverclass);
//获取链接
connection con = drivermanager.getconnection(url, user,password);
//获取预编译的statement
callablestatement pst= con.preparecall("{call add_sal(?,?)}");
pst.setint(1, 7499);
pst.setint(2, 1000);
//执行查询
pst.execute();
con.close();
//关闭连接
}catch(exception e){
e.printstacktrace();
}
}
/*存储过程的调用
* {call <procedure-name>[(<arg1>,<arg2>, ...)]}
count_yearsal(eno number,total_year_sal out number)
* */
@test
public void callcountsal(){
try{
//加载驱动
class.forname(driverclass);
//获取链接
connection con = drivermanager.getconnection(url, user,password);
//获取预编译的statement
callablestatement pst= con.preparecall("{call count_yearsal(?,?)}");
pst.setint(1, 7499);
//注册输出参数
pst.registeroutparameter(2, oracletypes.number);
//执行查询
pst.execute();
int total = pst.getint(2);
system.out.println(total);
con.close();
//关闭连接
}catch(exception e){
e.printstacktrace();
}
}
/*
* pro_dept_emp(dno number,dept_emp out sys_refcursor)
* */
@test
public void callproemp(){
try{
//加载驱动
class.forname(driverclass);
//获取链接
connection con = drivermanager.getconnection(url, user,password);
//获取预编译的statement
callablestatement pst= con.preparecall("{call pro_dept_emp(?,?)}");
pst.setint(1, 10);
//注册输出参数
pst.registeroutparameter(2, oracletypes.cursor);
//执行查询
pst.execute();
oraclecallablestatement ocs = (oraclecallablestatement)pst;
resultset rs = ocs.getcursor(2);
while(rs.next()){
system.out.println(rs.getint(1)+"员工姓名"+rs.getstring("ename"));
}
rs.close();
ocs.close();
pst.close();
con.close();
//关闭连接
}catch(exception e){
e.printstacktrace();
}
}
}
public void show4(){
try {
class.forname(driverclass);
connection con = drivermanager.getconnection(url, user,password);
callablestatement pst= con.preparecall("{?= call count_sal_noout(?)}");
//给第二个参数赋值
pst.setlong(2, 7499);
// stat2.setlong(2, empno);
//声明第一个参数的类型
pst.registeroutparameter(1, oracletypes.number);
pst.execute();
oraclecallablestatement ocs = (oraclecallablestatement)pst;
number num = ocs.getnumber(1);
system.out.println(num);
// long i = pst.getlong(1);
// system.out.println(i);
con.close();
} catch (exception e) {
e.printstacktrace();
}
}
/*
