- 浏览: 704931 次
- 性别:
- 来自: 北京
文章分类
- 全部博客 (272)
- Struts1.x (7)
- 事务 (2)
- Hibernate (11)
- 数据库 (14)
- JavaScript&Ajax (43)
- JSP&Servlet (2)
- Flex (1)
- 其它 (9)
- Java (22)
- 框架集成 (1)
- WebService (3)
- Tomcat (3)
- 加密和安全登录 (13)
- 基于原型的JavaScript (0)
- JavaDoc和Java编码规范 (3)
- CAS (1)
- 加密 (1)
- Axis2 (10)
- Ext2.x (3)
- SSH整合 (2)
- Ext (0)
- 正则表达式 (1)
- 设计模式 (4)
- 对象序列化技术 (3)
- CVS (2)
- Struts2 (6)
- Spring 2.x (7)
- Spring Security (2)
- Java 课程 (20)
- 程序员之死 (1)
- 软件测试 (6)
- UML (5)
- NetBeans (1)
- cxf (1)
- JMS (13)
- 设计 (5)
- ibatis2.x (3)
- Oracle (1)
- WebSphere (7)
- 概要设计 (1)
- DB2 (10)
- PowerDesigner (0)
- 软件工程 (5)
- rose (1)
- EA (1)
- LDAP (7)
- Portal&Portlet (3)
- MQ (10)
- ESB (4)
- EJB (2)
- JBoss (2)
最新评论
-
typeRos:
只有配置文件,没有代码么大神
Spring实现IBMMQ的JMS消息发布/订阅模式 -
panamera:
如果ActiveMQ服务器没有启动,这个时候消息生产者使用Jm ...
Spring JMSTemplate 与 JMS 原生API比较 -
lian819:
顶1楼, 引用文件, 配置属性, 太方便了
EXTJS 同步和异步请求 -
wilhard:
说得清楚明白
<%@ include file=""%>与<jsp:include page=""/>区别 -
刘琛颖:
总结的很好。受益了
javascript 父窗口(父页面)— 子窗口 (子页面)互相调用的方法
一、SQL 语句基础
SQL 的全称是 Structured Query Language,也就是结构化查询语言,使用 SQL 语句,程序员和数据库管理员(DBA)可以完成如下的任务:
- 在数据库中检索需要的信息
- 对数据库的信息进行更新
- 改变数据库的结构
- 更改系统的安全设置
- 增加用户对数据库或表的许可权限
上面 5 个任务中,一般程序员可以管理前 3 个任务,但后面 2 个任务通常由 DBA 来完成。
标准 SQL 语句通常可分为如下几种类型:
- 查询语句 select
- DML 语句(Data Manipulation Language,即数据库操作语言):insert、update、delete
- DDL 语句(Data Definition Language,即数据定义语言):create、alert、drop、truncate
- DCL 语句(Data Control Languate,即数据库控制语言):grant、revoke
- 事务控制语言:commit、rollback、savepoint
1、DDL 语句
create、drop、alert
创建表的语法:
create table [模式名.]表名
(
columnName1 datatype [default expr],
……
)
MySql 建表语句示例:
DROP TABLE IF EXISTS `cm_qyinfo`;
CREATE TABLE `cm_qyinfo` (
`id` varchar(32) NOT NULL COMMENT '主键',
`code` varchar(50) DEFAULT NULL COMMENT '与企业代码表的dmkey相关联',
`qymc` varchar(100) DEFAULT NULL COMMENT '企业名称',
`qydm` varchar(50) DEFAULT NULL COMMENT '企业代码',
`qyjc` varchar(100) DEFAULT NULL COMMENT '企业简称',
`nsrsbh` varchar(64) DEFAULT NULL,
`lxr` varchar(50) DEFAULT NULL,
`txdz` varchar(200) DEFAULT NULL COMMENT '通信地址',
`lxdh` varchar(50) DEFAULT NULL COMMENT '联系电话',
`email` varchar(100) DEFAULT NULL,
`post` varchar(10) DEFAULT NULL,
`cwzj` varchar(32) DEFAULT NULL COMMENT '财务总监',
`cwzg` varchar(32) DEFAULT NULL COMMENT '财务主管',
`fatherId` varchar(32) DEFAULT NULL,
PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
上面这种常见的建表语句只能创建一个空表,该表中没有任何数据。如果使用子查询建表语句则可以在建表的同时插入数据。
create table [模式名.]表名
[column(, column...)]
as subsquery;
上面语法中新表的字段列表必须与子查询中的字段列表数量匹配,创建新表时的字段列表可以省略,如果省略了该字段列表,则新表的列名与选择结果完全相同。例如:
create table test2 as select * from resc;
修改表结构的语法
增加列:
alter table 表名
add
(
column_name1 datatype [default expr],
……
);
修改列:
alter table 表名
modify column_name datatype [default expr] [first | after col_name];
删除列:
alter table 表名
drop column_name;
上面介绍的这些增加、修改和删除列的语法是标准的 SQL 语法,MySql 还提供了两种特殊的语法:重命名数据表和完全改变列定义。
重命名数据表的语法如下:
alert table 表名
rename 新表名;
完全改变列定义:
change old_column_name new_column_name type [default expr] [first | after col_name]
删除表的语法:
drop table 表名;
删除数据表的效果如下:
- 表结构被删除,表对象不再存在
- 表里所有的数据也被删除
- 该表所有相关的索引、约束也被删除
truncate 表
对于大多数数据库而言,truncate 都被当做 DDL 处理,truncate 被称为“截断”某个表——它的作用是删除该表里的全部数据,但保留表结构。truncate 相对于 DML 里的 delete 命令而言,truncate 的速度要快得多,而且 truncate 不像 delete 可以删除指定的记录,truncate 只能一次性删除整个表的全部记录。truncate 命令的语法如下:
truncate 表名;
约束概述:
大多数数据库支持下面五类完整性约束:
- NOT NULL:非空约束 ,指定某列不能为空。
- UNIQUE:唯一约束,指定某列或者几列组合不能重复。
- PRIMARY KEY:主键,指定该列的值可以唯一地标识该条记录。
- FOREIGN KEY:外键,指定该行记录从属于主表中的一条记录,主要用于保证参照完整性。
- CHECK:检查,指定一个布尔表达式,用于指定对应列的值必须满足该表达式。
根据约束对数据列的限制,可分为两列:
- 单列约束
- 多列约束
NOT NULL 非空约束
在建表示指定非空约束:
CREATE TABLE `cm_ztlink`
(
`ztdm` varchar(32) NOT NULL COMMENT '帐套代码',
`ztmc` varchar(200) NULL COMMENT '帐套名称'
) ;
在修改表时指定或者修改非空约束:
-- 增加非空约束
alter table cm_ztlink
modify ztmc varchar(200) NOT NULL;
-- 删除非空约束
alter table cm_ztlink
modify ztmc varchar(200) NULL;
UNIQUE 约束
唯一性约束用于保证指定列或者指定列的组合不允许出现重复值,虽然唯一性约束的列不允许出现重复值,但可以出现多个null。
唯一约束既可以在列级约束语法建立,也可以在表级约束约束语法上建立。
列级语法:
create table unique_test
(
test_name varchar(255) unique
);
如果需要为多列组合建立唯一约束,或者想自行指定约束名则需要使用表级约束语法:
[constraint 约束名] 约束定义
示例:
create table unique_test2
(
test_id int not null,
test_name varchar(255),
test_pass varchar(255),
-- 使用表级约束语法建唯一约束
unique (test_name),
-- 使用表级约束语法建唯一约束,而且指定约束名
constraint test2_uk unique(test_pass)
);
为两列组合建立唯一约束:
create table unique_test3
(
test_id int not null,
test_name varchar(255),
test_pass varchar(255),
-- 使用表级约束语法建立唯一约束,指定两列组合不能重复
constraint test3_uk unique(test_name, test_pass)
);
也可以在修改表结构时使用 add 关键字来增加唯一约束
alter table unique_test3
add unique(test_name, test_pass);
也可以在修改表时使用 modify 关键字、为单列采用列级约束语法来增加唯一约束
alter table haha
modify test_name varchar(255) unique;
对于大多数数据库而言,删除约束都是在 alter table 语句后使用 drop constraint 约束名的语法来删除约束,但 MySql 是使用 drop index 约束名的方式来删除约束。
alter table unique_test3
drop index test3_uk;
PRIMARY KEY 约束
主键约束相当于非空约束和唯一约束功能的集合,当创建主键约束时,MySql 在主键约束所在列或列组合上建立对应的唯一索引。
列级语法建立主键约束
create table primary_test
(
test_id int primary key,
test_name varchar(255)
);
表级约束语法建立主键索引
create table primary_test2
(
test_id int not null,
test_name varchar(255),
constraint test2_pk primary key(test_id)
);
使用 add 指令为表增加表级约束语法增加主键约束
alter table primary_test3
add primary key(test_name, test_pass);
使用 modify 指令使用列级约束语法在单独一列上增加主键约束
alter table primary_test3
modify test_name varchar(255) primary key;
表级约束建立组合主键
create table primary_test3
(
test_name varchar(255),
test_pass varchar(255),
primary key(test_name, test_pass)
);
删除主键约束
alter table primary_test3
drop primary key;
将主键列设置为自增列:
create table primary_test4
(
test_id int auto_increment primary key,
test_name varchar(255),
test_pass varchar(255)
);
FOREIGN KEY 约束
外键约束主要用于保证一个或者两个表之间的参照完整性。
从表外键参照的只能是主表主键列或者唯一键列,这样才能保证从表记录可以准确定位到被参照的主表记录。同一个表内可以有多个外键。
使用列级约束语法建立外键约束直接使用 references 关键字,reference 指定该列参照的哪个主表以及参照主表的哪一列。示例:
create table teacher_table1
(
teacher_id int auto_increment,
teacher_name varchar(255),
constraint teacher_table1_pk primary key(teacher_id)
);
create table student_table1
(
student_id int auto_increment primary key,
student_name varchar(255),
java_teacher int references teacher_table1(teacher_id)
);
表级约束语法创建外键约束:
create table teacher_table
(
teacher_id int auto_increment,
teacher_name varchar(255),
constraint teacher_table1_pk primary key(teacher_id)
);
create table student_table
(
student_id int auto_incretment primary key,
student_name varchar(255),
java_teacher int,
foreign key(java_teacher) references teacher_table(teacher_id)
);
使用 constraint 指令指定自定义外键名的外键约束
create table teacher_table2
(
teacher_id int auto_increment,
teacher_name varchar(255),
constraint teacher_table1_pk primary key(teacher_id)
);
create table student_table2
(
student_id int auto_increment primary key,
student_name varchar(255),
java_teacher int,
constraint student_teacher_fk foreign key(java_teacher) references teacher_table2(teacher_id)
);
如果需要建立多个列组合的外键约束,则必须使用表级约束语法,例如:
create table teacher_table3
(
teacher_name varchar(255),
teacher_pass varchar(255),
constraint twopk primary key(teacher_name, teacher_pass)
);
create table student_table3
(
student_id int auto_increment primary key,
student_name varchar(255),
java_teacher_name varchar(255),
java_teacher_pass varchar(255),
foreign key(java_teacher_name, java_teacher_pass)
references teacher_table3(teacher_name, teacher_pass)
);
删除外间的语法:
alert table student_table3
drop foreign key student_table3_ibfk_1;
增加外键约束
alter table student_table3
add foreign key(java_teacher_name, java_teacher_pass) references teacher_table3(teacher_name, teacher_pass)
外键约束不仅可以参照其它表,也可以参照自身,通常被称为“自关联”。例如:
create table foreign_test
(
foreign_id int auto_increment primary key,
foreign_name varchar(255),
refer_id int,
foreign key(refer_id) references foreign_test(foreign_id)
);
如果想定义当删除主表记录时,从表记录也会随之删除,则需要在建立外键约束后添加 on delete cascade 或添加 on delete set null,第一种是删除主表记录时,把参照该主表记录的从表记录全部级联删除;第二种是指定当删除主表记录时,把参照该主表记录的从表记录的外键设为 null。例如:
create table teacher_table4
(
teacher_id int auto_increment,
teacher_name varchar(255),
primary key(teacher_id)
);
create table student_table4
(
student_id int auto_increment primary key,
student_name varchar(255),
java_teacher int,
foreign key(java_teacher) references teacher_table4(teacher_id) on delete cascade
);
CHECK 约束
例:
create table check_test
(
emp_id int auto_increment,
emp_name varchar(255),
emp_salary decimal,
primary key(emp_id),
-- 建立 CHECK 约束
check (emp_salary > 0)
);
索引
创建索引有两种方式:
- 自动:当在表上定义主键约束、唯一约束和外键约束时,系统会为该数据列自动创建对应的索引
- 手动:用户可以手动创建索引来加速查询
删除索引也有两种方式:
- 自动:数据表被删除时,该表上的索引被自动删除
- 手动:用户可以手动删除指定数据表上的指定索引
创建索引的语法:
create index index_name on table_name (column[, column]……);
下面的索引将会提高对 EMPLOYEES 表基于 LAST_NAME 字段的查询速度
create index emp_last_name_index on emplyees(last_name);
也可以同时对多列建立索引:
create index emp_last_name_index2 on employees(firstname, last_name);
删除指定索引:
drop index 索引名 on 表名
视图
视图看上去非常像一个数据表,但它不是数据表,因为它并不能存储数据。视图只是一个或多个数据表中数据的逻辑显示。视图的好处:
- 可以限制对数据的访问
- 可以使复杂的查询变得简单
- 提供了数据的独立性
- 提供了对相同数据的不同显示
建立视图的语法 :
create or replace view 视图名
as
subquery
为了强制不允许改变视图的数据,大多数数据库允许在创建视图时使用 with check option 子句(Oracle 数据使用 with read only),使用该子句创建的视图不允许修改。例如:
create or replace view view_test
as
select teacher_name from teacher_table with check option;
删除视图:
drop view 视图名;
2、DML 语句语法
- 插入新数据
- 修改已有数据
- 删除不需要的数据
DML 主要由 insert into、update 和 delete from 三个命令组成。
insert into 语句
update 语句
delete from 语句
3、select 语句和 SQL 函数
当使用 select 语句进行查询时,还可以在 select 语句中使用算术运算符(+、-、*、/),从而形成算术表达式
- 对数值型数据列、变量、常量可以使用算术操作符(+、-、*、/)创建表达式
- 对日期型数据列、变量、常量可以使用部分算术操作符创建表达式(+、-),两个日期之间可以进行减法运算,日期和数值之间可进行加、减运算。
- 运算符不仅可以在列和常量、变量之间进行运算,也可以在两列之间进行运算。
示例:
select teacher_id + 5 from teacher_table;
select * from teacher_table where teacher_id * 3 > 4
从上面的 SQL 语句可以看出,select 后的不仅可以使数据列,也可以是表达式,甚至可以是变量常量等。
MySql 无法使用(+)将字符串常量、字符串变量或字符串列连接起来。MySql 使用 concat 函数进行字符串连接运算。
例如:select concat(teacher_name, 'XX') from teacher_table;
distinct 关键字。
一些特殊的比较运算符
运算符 含义
betwween val1 and val2 大于等于 val1,且小于等于 val2
in(list) 等于括号里多个值的任意之一
like 字符串匹配,like 后的字符串支持通配符
is null 要求指定值等于 null
使用 in 比较符时,必须在 in 后的括号里列出一个或多个值,它要求指定列必须与 in 括号里任意一个值相等。
示例:select * from student_table where student_id in (2, 4);
与之类似的是,in 括号里的值既可以是常量,也可以是变量或列名,
示例:select * from student_table where 2 in (student_id, java_teacher);
like 运算符主要用于进行模糊查询,SQL 语句中可以使用两个通配符:下划线(_)和百分号(%),下划线可以代表一个任意字符,百分号可以代表任意多个字符。
在某些情况下,我们需要查询的条件里需要使用下划线或百分号,不希望 SQL 把下划线和百分号当成通配符使用,MySql 使用反斜线(\)作为转义字符,例如:
select * from student_table where student_name like '\_%';
在标准的 SQL 语句中并没有提供反斜线(\)的转义字符,而是使用 escape 关键字显式进行转义,例如为了实现上面功能需要使用如下 SQL 语句:
select * from student_table where student_name like '\_%' escape '\';
SELECT * FROM clubuser
WHERE (clubuser_name LIKE 'tes\_t' escape '\') and (clubuser_nickname like 't\_est' escape '\');
is null 用于判断某些值是否为空,判断是否为空不要用 = null 来判断,因为 SQL 中 null = null 返回 null。
select * from student_table where student_name is null;
SQL 中比较运算符、逻辑运算符的优先级
运算符 优先级(优先级小的优先)
所有比较运算符 1
not 2
and 3
or 4
例如:select * from student_table where not student_name like '\_%';
select * from student_table where not id < 10000;
排序:order by
数据库函数:多行函数、单行函数
MySql 数据库的数据类型大致可以分为数值型、字符型和日期时间型。
MySql 数据库的单行函数主要分为:
- 日期时间函数
- 数值函数
- 字符函数
- 转换函数
- 其他函数
转换函数主要负责完成类型转换,其他函数又可以大致分为如下几类:
- 位函数
- 流程控制函数
- 加密解密函数
- 信息函数
示例:
-- 选出 teacher_table 中 teacher_name 列的字符长度
select char_length(teacher_name) from teacher_table;
-- 计算 teacher_name 列的字符长度的 sin 值。
select sin(char_length(teacher_name)) from teacher_table;
-- 计算 1.57 的 sin 值,约等于 1
select sin(1.57);
-- 为指定日期加上一定的时间
-- 在这种用法下 interval 是关键字,需要一个数值,还需要一个单位
select date_add('1981-10-01', interval 2 month);
-- 这种用法更简单
select adddate('1981-01-01', 3);
-- 获取当前日期
select curdate();
-- 获取当前时间
select curtime();
-- 下面的 md5 是 md5 的加密函数
select MD5('testing');
MySql 提供了三个处理 null 的函数:
- ifnull(expr1, expr2): 如果 expr1 为 null,返回 expr2,否则返回 expr1.
- nullif(expr1, expr2): 如果 expr1 和 expr2 相等,则返回 null,否则返回 expr1.
- if(expr1, expr2, expr3): 有点类似于 ? : 三目运算符,如果 expr1 为 true,不等于 0,且不等于 null,返回 expr2,否则返回 expr3.
- isnull(expr1): 判断 expr1 是否为 null,如果为 null 返回 true,否则返回 false。
MySql 还提供了一个 case 函数,它是一个流程控制函数,case 函数的语法如下:
case value
when compare_value1 then result1
when compare_value2 then result2
……
else result
end
示例:
-- 如果学生的 java teacher 为 1,则返回 'Java 老师',为 2 则返回 'Ruby 老师',否则返回 '其他老师'
select student_name, case java_teacher
when 1 then 'Java 老师'
when 2 then 'Ruby 老师'
else '其他老师'
end
from student_table;
4、分组和组函数
组函数就是前面提到的多行函数,常用的组函数有:
- avg([distinct|all]expr)
- count({*|[distinct|all]expr})
- max([distinct]expr)
- sum([distinct]expr)
- min([distinct]expr)
- max([distinct]expr)
示例:
-- 计算 student_table 表中的记录条数
select count(*) from student_table;
-- 计算 Java_teacher 列总共有多少个值
select count(distinct java_teacher) from student_table;
-- 统计所有 student_id 的总和
select sum(student_id) from student_table;
-- 计算的结果是 20 * 记录的行数
select sum(20) from student_table;
-- 选出 student_table 中 student_id 的最大值
select max(student_id) from student_table;
-- 因为 sum 里的 expr 是常量 34,所有每行的值相同,使用 distinct 强制不计算重复值,所以下面的计算结果是 34
select sum(distinct 34) from student_table;
-- 使用 count 统计记录行数时, null 不会被算在内
select count(student_name) from student_table;
-- 对于可能出现 null 的列,可以使用 ifnull 函数来处理该列
-- 计算 java_teacher 列所有记录的平均值
select avg(ifnull(java_teacher, 0)) from student_table;
二、JDBC 的典型用法
1、JDBC 提供了独立于数据库的统一 API,用于执行 SQL 命令。JDBC API 由以下常用接口和类组成:
DriverManager:
- public static synchronized Connection getConnection(String url, String user, String pass) throws SQLException
Connection:
- Statement createStatement() throws SQLException
- PreparedStatement prepareStatement(String sql) throws SQLException
- CallableStatement prepareCall(String sql) throws SQLException
- Savepoint setSavepoint()
- Savepoint setSavepoint(String name)
- void setTransacionIsolation(int level)
- void rollback()
- void rollback(Savepoint savepoint)
- void setAutoCommit(boolean autoCommit)
- void commit()
Statement:
- ResultSet executeQuery(String sql) throws SQLException
- int executeUpdate(String sql) throws SQLException
- boolean execute(String sql) throws SQLException
PreparedStatement
- void setXxx(int parameterIndex, Xxx value)
ResultSet
- void close() throws SQLException
- boolean absolute(int row)
- void beforeFirst()
- boolean first()
- boolean previous()
- boolean next()
- boolean last()
- void afterLast()
2、JDBC 编程步骤
- 加载数据库驱动
// 加载驱动
Class.forName(driverClass)
- 通过 DriverManager 获取数据库连接
// 获取数据库连接
DriverManager.getConnection(String url, String user, String pass)
- 通过 Connection 对象创建 Statement 对象,Connection 创建 Statement 的方法有如下三个:
1)createStatement()
2)prepareStatement(String sql)
3)prepareCall(String sql)
- 使用 Statement 执行 SQL 语句
1)execute
2)executeUpdate
3)executeQuery
- 操作结果集
1)next、previous、first、last、beforeFirst、afterLast、absolute
2)getXxx 获取记录指针指向行,特定列的值。该方法既可使用列索引作为参数,也可使用列名作为参数。使用列索引作为参数性能更好,使用列名作为参数可读性更好。
- 回收数据库资源,包括关闭 ResultSet、Statement 和 Connection 等资源
示例:
import java.sql.*;
public class ConnMySql
{
public static void main(String[] args) throws Exception
{
//1.加载驱动,使用反射的知识,现在记住这么写。
Class.forName("com.mysql.jdbc.Driver");
//2.使用DriverManager获取数据库连接,
//其中返回的Connection就代表了Java程序和数据库的连接
//不同数据库的URL写法需要查驱动文档知道,用户名、密码由DBA分配
Connection conn = DriverManager.getConnection(
"jdbc:mysql://127.0.0.1:3306/select_test" ,
"root" , "32147");
//3.使用Connection来创建一个Statment对象
Statement stmt = conn.createStatement();
//4.执行SQL语句。
/*
Statement有三种执行sql语句的方法:
1 execute 可执行任何SQL语句。- 返回一个boolean值,
如果执行后第一个结果是ResultSet,则返回true,否则返回false
2 executeQuery 执行Select语句 - 返回查询到的结果集
3 executeUpdate 用于执行DML语句。- 返回一个整数,代表被SQL语句影响的记录条数
*/
ResultSet rs = stmt.executeQuery("select s.* , teacher_name from student_table s , "
+ "teacher_table t where t.teacher_id = s.java_teacher");
//ResultSet有系列的getXxx(列索引 | 列名),用于获取记录指针指向行、特定列的值
//不断地使用next将记录指针下移一行,如果依然指向有效行,则指针指向行的记录
while(rs.next())
{
System.out.println(rs.getInt(1) + "\t"
+ rs.getString(2) + "\t"
+ rs.getString(3) + "\t"
+ rs.getString(4));
}
if (rs != null)
{
rs.close();
}
if (stmt != null)
{
stmt.close();
}
if (conn != null)
{
conn.close();
}
}
}
四、执行 SQL 语句的方式
1、使用 executeUpdate 执行 DDL 和 DML 语句
示例:
mysql.ini:
driver=com.mysql.jdbc.Driver
url=jdbc:mysql://127.0.0.1:3306/select_test
user=root
pass=32147
ExecuteDDL:
import java.sql.*;
import java.util.*;
import java.io.*;
public class ExecuteDDL
{
private String driver;
private String url;
private String user;
private String pass;
Connection conn;
Statement stmt;
public void initParam(String paramFile)throws Exception
{
//使用Properties类来加载属性文件
Properties props = new Properties();
props.load(new FileInputStream(paramFile));
driver = props.getProperty("driver");
url = props.getProperty("url");
user = props.getProperty("user");
pass = props.getProperty("pass");
}
public void createTable(String sql)throws Exception
{
try
{
//加载驱动
Class.forName(driver);
//获取数据库连接
conn = DriverManager.getConnection(url , user , pass);
//使用Connection来创建一个Statment对象
stmt = conn.createStatement();
//执行DDL,创建数据表
stmt.executeUpdate(sql);
}
//使用finally块来关闭数据库资源
finally
{
if (stmt != null)
{
stmt.close();
}
if (conn != null)
{
conn.close();
}
}
}
public static void main(String[] args) throws Exception
{
ExecuteDDL ed = new ExecuteDDL();
ed.initParam("mysql.ini");
ed.createTable("create table jdbc_test "
+ "( jdbc_id int auto_increment primary key, "
+ "jdbc_name varchar(255), "
+ "jdbc_desc text);");
System.out.println("---------建表成功--------");
}
}
使用 executeUpdate 执行 DML 与执行 DDL 基本相似,区别是 executeUpdate 执行 DDL 返回 0,而执行 DML 后返回受影响的记录条数。
示例:ExecuteDML
import java.sql.*;
import java.util.*;
import java.io.*;
public class ExecuteDML
{
private String driver;
private String url;
private String user;
private String pass;
Connection conn;
Statement stmt;
public void initParam(String paramFile)throws Exception
{
//使用Properties类来加载属性文件
Properties props = new Properties();
props.load(new FileInputStream(paramFile));
driver = props.getProperty("driver");
url = props.getProperty("url");
user = props.getProperty("user");
pass = props.getProperty("pass");
}
public int insertData(String sql)throws Exception
{
try
{
//加载驱动
Class.forName(driver);
//获取数据库连接
conn = DriverManager.getConnection(url , user , pass);
//使用Connection来创建一个Statment对象
stmt = conn.createStatement();
//执行DML,返回受影响的记录条数
return stmt.executeUpdate(sql);
}
//使用finally块来关闭数据库资源
finally
{
if (stmt != null)
{
stmt.close();
}
if (conn != null)
{
conn.close();
}
}
}
public static void main(String[] args) throws Exception
{
ExecuteDML ed = new ExecuteDML();
ed.initParam("mysql.ini");
int result = ed.insertData("insert into jdbc_test(jdbc_name,jdbc_desc)"
+ "select s.student_name , t.teacher_name "
+ "from student_table s , teacher_table t "
+ "where s.java_teacher = t.teacher_id;");
System.out.println("------系统中共有" + result + "条记录受影响------");
}
}
2、使用 execute 方法执行 SQL 语句
Statement 的 execute 方法几乎可以执行任何 SQL 语句,但它执行 SQL 语句时比较麻烦,通常使用 executeQuery 和 executeUpdate 更合适。但如果再不清楚 SQL 语句的类型时,则只能使用 execute 方法。
当使用 execute 方法执行了 SQL 语句后返回值只是 boolean 值,表明执行该 SQL 语句是否返回了 ResultSet 对象,如果返回了 ResultSet 对象,则可以使用 Statement 提供的如下两个方法获取结果集:
- getResultSet()
- getUpdateCount()
示例:ExecuteSQL
import java.sql.*;
import java.util.*;
import java.io.*;
public class ExecuteSQL
{
private String driver;
private String url;
private String user;
private String pass;
Connection conn;
Statement stmt;
ResultSet rs;
public void initParam(String paramFile)throws Exception
{
//使用Properties类来加载属性文件
Properties props = new Properties();
props.load(new FileInputStream(paramFile));
driver = props.getProperty("driver");
url = props.getProperty("url");
user = props.getProperty("user");
pass = props.getProperty("pass");
}
public void executeSql(String sql)throws Exception
{
try
{
//加载驱动
Class.forName(driver);
//获取数据库连接
conn = DriverManager.getConnection(url , user , pass);
//使用Connection来创建一个Statment对象
stmt = conn.createStatement();
//执行SQL,返回boolean值表示是否包含ResultSet
boolean hasResultSet = stmt.execute(sql);
//如果执行后有ResultSet结果集
if (hasResultSet)
{
//获取结果集
rs = stmt.getResultSet();
//ResultSetMetaData是用于分析结果集的元数据接口
ResultSetMetaData rsmd = rs.getMetaData();
int columnCount = rsmd.getColumnCount();
//迭代输出ResultSet对象
while (rs.next())
{
//依次输出每列的值
for (int i = 0 ; i < columnCount ; i++ )
{
System.out.print(rs.getString(i + 1) + "\t");
}
System.out.print("\n");
}
}
else
{
System.out.println("该SQL语句影响的记录有" + stmt.getUpdateCount() + "条");
}
}
//使用finally块来关闭数据库资源
finally
{
if (rs != null)
{
rs.close();
}
if (stmt != null)
{
stmt.close();
}
if (conn != null)
{
conn.close();
}
}
}
public static void main(String[] args) throws Exception
{
ExecuteSQL es = new ExecuteSQL();
es.initParam("mysql.ini");
System.out.println("------执行删除表的DDL语句-----");
es.executeSql("drop table if exists my_test");
System.out.println("------执行建表的DDL语句-----");
es.executeSql("create table my_test"
+ "(test_id int auto_increment primary key, "
+ "test_name varchar(255))");
System.out.println("------执行插入数据的DML语句-----");
es.executeSql("insert into my_test(test_name) "
+ "select student_name from student_table");
System.out.println("------执行查询数据的查询语句-----");
es.executeSql("select * from my_test");
}
}
3、使用 PreparedStatement 执行 SQL 语句
JDBC 的 PreparedStatement 接口可以用来执行使用问号占位符的 SQL 语句,PreparedStatement 接口是 Statement 接口的子接口,它可以预编译 SQL 语句,预编译后的 SQL 语句被存储在 PreparedStatement 对象中,然后可以使用该对象多次高效地执行该语句,所以 PreparedStatement 比使用 Statement 的效率高。
创建 PreparedStatement 对象使用 Connection 的 prepareStatement 方法,该方法需要传入一个 SQL 字符串,该字符串可以包含占位符参数:
// 创建一个 PreparedStatement 对象
pstmt = conn.prepareStatement("insert into student_table values(null, ?, 1)");
PreparedStatement 提供了系列的 setXxx(int index, Xxx value) 方法来传入参数值。
示例:
import java.sql.*;
import java.util.*;
import java.io.*;
public class PreparedStatementTest
{
private String driver;
private String url;
private String user;
private String pass;
Connection conn;
Statement stmt;
PreparedStatement pstmt;
public void initParam(String paramFile)throws Exception
{
//使用Properties类来加载属性文件
Properties props = new Properties();
props.load(new FileInputStream(paramFile));
driver = props.getProperty("driver");
url = props.getProperty("url");
user = props.getProperty("user");
pass = props.getProperty("pass");
}
public void insertUseStatement()throws Exception
{
long start = System.currentTimeMillis();
try
{
//使用Connection来创建一个Statment对象
stmt = conn.createStatement();
//需要使用100条SQL语句来插入100条记录
for (int i = 0; i < 100 ; i++ )
{
stmt.executeUpdate("insert into student_table values(null,'姓名"
+ i + "',1)");
}
System.out.println("使用Statement费时:" + (System.currentTimeMillis() - start));
}
//使用finally块来关闭数据库资源
finally
{
if (stmt != null)
{
stmt.close();
}
}
}
public void insertUsePrepare()throws Exception
{
long start = System.currentTimeMillis();
try
{
//使用Connection来创建一个PreparedStatment对象
pstmt = conn.prepareStatement("insert into student_table values(null,?,1)");
//100次为PreparedStatement的参数设置,就可以插入100条记录
for (int i = 0; i < 100 ; i++ )
{
pstmt.setString(1 , "姓名" + i);
pstmt.executeUpdate();
}
System.out.println("使用PreparedStatement费时:" + (System.currentTimeMillis() - start));
}
//使用finally块来关闭数据库资源
finally
{
if (pstmt != null)
{
pstmt.close();
}
}
}
//定义打开连接的方法
public void getConn()throws Exception
{
if (conn == null)
{
//加载驱动
Class.forName(driver);
//获取数据库连接
conn = DriverManager.getConnection(url , user , pass);
}
}
//定义关闭连接的方法
public void closeConn()throws Exception
{
if (conn != null)
{
conn.close();
}
}
public static void main(String[] args) throws Exception
{
PreparedStatementTest pt = null;
try
{
pt = new PreparedStatementTest();
pt.initParam("mysql.ini");
pt.getConn();
pt.insertUseStatement();
pt.insertUsePrepare();
}
finally
{
pt.closeConn();
}
}
}
4、管理结果集
1)可滚动、可更新的结果集
以默认的方式打开的 ResultSet 是不可更新的,如果希望创建可更新的 ResultSet,必须在创建 Statement 或 PreparedStatement 的时候传入额外的参数。Connection 在创建 Statement 或 PreparedStatement 时还可传入两个参数。
- resultSetType:控制 ResultSet 的类型,该参数可以是如下三个值:
ResultSet.TYPE_FORWARD_ONLY:该常量控制记录指针只能向前移动
ResultSet.TYPE_SCROLL_INSENSITIVE:该常量控制记录指针可以自由移动(可滚动结果集),但是底层数据的改变不会影响 ResultSet 的内容。
ResultSet.TYPE_SCROLL_SENCITIVE:该常量控制记录指针可以自由移动(可滚动结果集),并且底层数据的改变会影响 ResultSet 的内容。
- ResultSetConcurrency:控制 ResultSet 的并发类型,该参数可接受如下两个值:
ResultSet.CONCUR_READ_ONLY:该常量指示 ResultSet 是只读的并发模式(默认)
ResultSet.CONCUR_UPDATABLE:该常量指示 ResultSet 是可更新的并发模式
下面代码通过这两个参数创建了一个 PreparedStatement 对象,由该对象生成的 ResultSet 对象将是可滚动、可更新的结果集:
// 使用 Connection 来创建一个 PreparedStatement 对象
// 传入控制结果可滚动、可更新的参数
pstmt = conn.prepareStatement(sql, ResultSet.TYPE_SCROLL_INSENCITIVE, ResultSet.CONCUR_UPDATABLE);
程序可以通过调用 ResultSet 的 updateXxx(int columnIndex, Xxx value) 来修改记录指针所指记录的特定列的值,最后调用 ResultSet 的 updateRow 来提交修改。
发表评论
-
java:comp/env 解释
2012-07-13 13:40 10827关于获取数据源的语法,大体有(javax.sql.D ... -
java.naming.factory.url.pkgs 的用途
2012-06-28 09:48 1755原文地址:http://blog.csdn.net/l ... -
解析 HTTP
2010-11-14 18:09 48043、HTTP 请求 客户端通过发送 HTTP 请求向服务器 ... -
Tomcat server.xml 文件
2010-11-07 17:21 1223Tomcat 服务器有一系列可配置的组件构成,这些组件 ... -
Tomcat的体系结构
2010-11-04 21:13 1481Tomcat的体系结构 Tomcat服务器是由一系列可配 ... -
第十四课时: 输入/输出1
2010-10-30 20:48 1315Java 的 IO 支持通过 java.io 包 ... -
第十七课时: 网络编程
2010-10-18 22:00 1151一. 网络编程的基础知 ... -
第十六课时: 多线程
2010-10-07 14:24 980一. 继承 Thread 类创建线程 通过继承 Thread ... -
第十四课时:输入/输出2
2010-09-05 15:54 1250... -
第十三课时:Annotation 注释
2010-08-29 15:55 1130从 JDK 5.0 开始,Java 增加了对元数据 ( ... -
第十二课时:JDBC 编程 (2)
2010-08-28 13:13 875示例: import java.sql.*; impor ... -
第11课时:异常处理
2010-07-25 16:51 1144一、异常处理机制 1、使用 try...catch 捕获异常 ... -
第十课时:与运行环境交互
2010-07-24 06:03 777一、与用户交互 1、使用 Scanner 获取键盘输入 获 ... -
第九课时:泛型
2010-07-11 17:00 1386一、定义泛型接口、类 JDK 1.5 改写了 ... -
第六课时:面向对象(5)—— 2010年05月22日
2010-07-04 13:45 988一、内部类 在某些情况下,我们把一个类放在另一个类的 ... -
第三课时:面向对象(2)
2010-05-02 23:20 1417一、成员变量与局部变量 二、类的继 ... -
第二课时:数组、面向对象(1)
2010-05-02 23:19 957一、数组 1、 ... -
第四课时:面向对象(3)
2010-05-02 23:17 902一、基本数据类型的包装类 1、 基本数据类型和包装 ... -
第一课时提纲:Java 基础(GC)
2010-03-22 23:22 1189一、Java 命名规范 1、对常量的命名规范: ...
相关推荐
phpcms v9 官方教程全集打包下载 第一课时:PHPCMS V9 系统设置 第二课时:PHPCMS V9 使用指南...第十课时:PHPCMS V9 采集管理 友情提示:教程为office2007版PPT,请下载office2007或office2003兼容2007组件打开。
七年级(初一)数学上册新人教版导学案第三章元一次方程第12课时:3.4实际问题与一元一次方程(1).pdf
课时1:阿里云整体架构.mp4 课时2:阿里云平台优势.mp4 课时3:云服务器ECS的概念.mp4 课时4:ECS实例.mp4 课时5:ECS的优势.mp4 课时6:ECS的使用.mp4 课时7:ECS的计费和使用限制.mp4 课时8:介绍阿里云块存储产品...
课时1:阿里云整体架构.mp4 课时2:阿里云平台优势.mp4 课时3:云服务器ECS的概念.mp4 课时4:ECS实例.mp4 课时5:ECS的优势.mp4 课时6:ECS的使用.mp4 课时7:ECS的计费和使用限制.mp4 课时8:介绍阿里云块存储产品...
课时1:阿里云整体架构.mp4 课时2:阿里云平台优势.mp4 课时3:云服务器ECS的概念.mp4 课时4:ECS实例.mp4 课时5:ECS的优势.mp4 课时6:ECS的使用.mp4 课时7:ECS的计费和使用限制.mp4 课时8:介绍阿里云块存储产品...
课时1:阿里云整体架构.mp4 课时2:阿里云平台优势.mp4 课时3:云服务器ECS的概念.mp4 课时4:ECS实例.mp4 课时5:ECS的优势.mp4 课时6:ECS的使用.mp4 课时7:ECS的计费和使用限制.mp4 课时8:介绍阿里云块存储产品...
课时1:阿里云整体架构.mp4 课时2:阿里云平台优势.mp4 课时3:云服务器ECS的概念.mp4 课时4:ECS实例.mp4 课时5:ECS的优势.mp4 课时6:ECS的使用.mp4 课时7:ECS的计费和使用限制.mp4 课时8:介绍阿里云块存储产品...
课时1:阿里云整体架构.mp4 课时2:阿里云平台优势.mp4 课时3:云服务器ECS的概念.mp4 课时4:ECS实例.mp4 课时5:ECS的优势.mp4 课时6:ECS的使用.mp4 课时7:ECS的计费和使用限制.mp4 课时8:介绍阿里云块存储产品...
课时1:阿里云整体架构.mp4 课时2:阿里云平台优势.mp4 课时3:云服务器ECS的概念.mp4 课时4:ECS实例.mp4 课时5:ECS的优势.mp4 课时6:ECS的使用.mp4 课时7:ECS的计费和使用限制.mp4 课时8:介绍阿里云块存储产品...
课时1:阿里云整体架构.mp4 课时2:阿里云平台优势.mp4 课时3:云服务器ECS的概念.mp4 课时4:ECS实例.mp4 课时5:ECS的优势.mp4 课时6:ECS的使用.mp4 课时7:ECS的计费和使用限制.mp4 课时8:介绍阿里云块存储产品...
课时1:阿里云整体架构.mp4 课时2:阿里云平台优势.mp4 课时3:云服务器ECS的概念.mp4 课时4:ECS实例.mp4 课时5:ECS的优势.mp4 课时6:ECS的使用.mp4 课时7:ECS的计费和使用限制.mp4 课时8:介绍阿里云块存储产品...
课时1:阿里云整体架构.mp4 课时2:阿里云平台优势.mp4 课时3:云服务器ECS的概念.mp4 课时4:ECS实例.mp4 课时5:ECS的优势.mp4 课时6:ECS的使用.mp4 课时7:ECS的计费和使用限制.mp4 课时8:介绍阿里云块存储产品...
课时1:阿里云整体架构.mp4 课时2:阿里云平台优势.mp4 课时3:云服务器ECS的概念.mp4 课时4:ECS实例.mp4 课时5:ECS的优势.mp4 课时6:ECS的使用.mp4 课时7:ECS的计费和使用限制.mp4 课时8:介绍阿里云块存储产品...
课时1:阿里云整体架构.mp4 课时2:阿里云平台优势.mp4 课时3:云服务器ECS的概念.mp4 课时4:ECS实例.mp4 课时5:ECS的优势.mp4 课时6:ECS的使用.mp4 课时7:ECS的计费和使用限制.mp4 课时8:介绍阿里云块存储产品...
课时1:阿里云整体架构.mp4 课时2:阿里云平台优势.mp4 课时3:云服务器ECS的概念.mp4 课时4:ECS实例.mp4 课时5:ECS的优势.mp4 课时6:ECS的使用.mp4 课时7:ECS的计费和使用限制.mp4 课时8:介绍阿里云块存储产品...
课时1:阿里云整体架构.mp4 课时2:阿里云平台优势.mp4 课时3:云服务器ECS的概念.mp4 课时4:ECS实例.mp4 课时5:ECS的优势.mp4 课时6:ECS的使用.mp4 课时7:ECS的计费和使用限制.mp4 课时8:介绍阿里云块存储产品...
课时1:阿里云整体架构.mp4 课时2:阿里云平台优势.mp4 课时3:云服务器ECS的概念.mp4 课时4:ECS实例.mp4 课时5:ECS的优势.mp4 课时6:ECS的使用.mp4 课时7:ECS的计费和使用限制.mp4 课时8:介绍阿里云块存储产品...
课时1:阿里云整体架构.mp4 课时2:阿里云平台优势.mp4 课时3:云服务器ECS的概念.mp4 课时4:ECS实例.mp4 课时5:ECS的优势.mp4 课时6:ECS的使用.mp4 课时7:ECS的计费和使用限制.mp4 课时8:介绍阿里云块存储产品...
课时1:阿里云整体架构.mp4 课时2:阿里云平台优势.mp4 课时3:云服务器ECS的概念.mp4 课时4:ECS实例.mp4 课时5:ECS的优势.mp4 课时6:ECS的使用.mp4 课时7:ECS的计费和使用限制.mp4 课时8:介绍阿里云块存储产品...