JDBC作为JavaEE的一部分,在web项目中都直接或者间接使用其来操作数据库,无需开发人员针对某种特别的数据库进行编程。下面文章描述数据库基本的操作,以及涉及JDBC 3.0的内容。
技术群:466473786
(1):基本使用方法
- 载入数据库驱动 到使用的数据库官方下载jar包驱动
- 建立数据库连接,获取Connection对象
- 获取statement 对象或者preparedstatement(编译sql)
- 根据SQL语句拿到拿到rusultset 进行操作
-代码展示:
package my.test.utils;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class MyJdbc {
private static final String password = "123456";
private static final String user = "root";
private static final String url = "jdbc:mysql://localhost:3306/wsy_student";
public static void main(String[] args) {
// - 载入数据库驱动 到使用的数据库官方下载jar包驱动
try {
Class.forName("com.mysql.jdbc.Driver");
// - 建立数据库连接,获取Connection对象
Connection con = DriverManager.getConnection(url, user, password);
// - 获取statement 对象或者preparedstatement(编译sql)
Statement statement = con.createStatement();
// - 根据SQL语句拿到拿到rusultset 进行操作
ResultSet query = statement.executeQuery("select * from user");
while (query.next()) {
System.out.println("删除成功"+ query.getString("username"));
}
} catch (ClassNotFoundException | SQLException e) {
e.printStackTrace();
}
}
}
(2)preparedstatement的使用优点
- 可维护性,可读性高
- 能够最大地提高代码的执行效率
- 能够提高程序的安全性
-代码
PreparedStatement ps = con.prepareStatement("insert into user(username,password) value(?,?)");
//记住下标是从1开始
ps.setString(1, "user1");
ps.setString(2, "pass");
ps.addBatch();
ps.executeBatch();
(3) 存储过程
- 存储过程的callstatement是继承自preparedstatement,拥有以下其方法,再则 遇到有参数的存储过程,多了一个registerOutParameter注册拿到结果
CallableStatement call = con.prepareCall("{call user procedurename(?,?,?)}");
call.setString(1, "proce1");
call.setString(2, "proce2");
//有参数输出的执行过程
call.registerOutParameter(3, java.sql.Types.INTEGER);
call.execute();
//拿到输出结果
int int1 = call.getInt(3);
(4)可更新的结果集(手动持久化)
- 通过preparedstatement的executeQuery()拿到结果集
- 移动结果集到当前行
- 使用updatexxx 进行操作
- 根据情况 执行持久化 inserrow(),deleterow(),updaterow()
- 注意需要设置 可滚动,可更新
ResultSet.TYPE_SCROLL_SENSITIVE,
ResultSet.CONCUR_UPDATABLE
-代码
Connection con = DbUtils.getConnection();
try {
PreparedStatement ps = con.prepareStatement("select * from user",ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE);
ResultSet executeQuery = ps.executeQuery();
//移动游标的插入行
executeQuery.moveToInsertRow();
//使用updatexxx
executeQuery.updateString(2, "use");
//进行持久化操作
executeQuery.insertRow();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
(5) 行集
- JDBC 3.0提出,解决了在可滚动,可更新的情况下connection资源紧张的问题。特点:断开数据库连接后,任然可以直接操作行集数据。
- 是resultset的子接口 rowset ,可以像resultset一样操作,数据集合
- 拥有五个不同的实现类,针对不同的问题选择不同的来处理数据
-cacherowset ,数据库离线支持,缓存在内存中,提供序列化支持,可作为javabean在网络间传输,支持事件监听,分页等 - webrowset ,提供rowset在xml间进行转化操作,相互操作。
- filteredrowset 提供过滤支持,需要可重写,predicate接口,完成数据过滤
- joinrowset ,可以提供连接查询,可以把不同的行集的数据结合起来
- jdbcrowset,唯一一个必须保持connection连接的行集,可提供序列化支持。
-下面简单列举,cacherowset的使用;
@Test
public void rowCollction() throws SQLException, ClassNotFoundException {
Class.forName("com.mysql.jdbc.Driver");
CachedRowSet crt=new CachedRowSetImpl();
crt.setUrl("jdbc:mysql://localhost:3306/wsy_student");
crt.setUsername("root");
crt.setPassword("123456");
//通过command来执行命令
crt.setCommand("select * from user");
crt.execute();
//遍历行集
while (crt.next()) {
System.out.println(crt.getString("username"));
}
}
(6) 事物处理
系统学习过数据库的都是应该知道事物的,事物提出,按照软件开发的五个基本原则进行,commit ,rollback ,我认为主要是为了数据的安全性。步骤
- 建议采用try cacth的方式进行管理异常,原因是可以回滚
- 静止自动提交操作
- 利用preparedstatement 执行操作,
- 手动进行操作提交
- 异常中管理回滚操作
-代码
Connection con = DbUtils.getConnection();
try {
con.setAutoCommit(false);
PreparedStatement ps = con.prepareStatement("select * from user",ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE);
ResultSet executeQuery = ps.executeQuery();
//移动游标的插入行
executeQuery.moveToInsertRow();
//使用updatexxx
executeQuery.updateString(2, "use");
//进行持久化操作
executeQuery.insertRow();
//手动进行提交
con.commit();
} catch (SQLException e) {
new Exception("出现了异常");
e.printStackTrace();
}
(7) 数据源以及JNDI
商业级别数据库应用,不会采用自己编写本次threadlcoal 的数据库连接池,一般会选择c3po,druid,dbcp,或者直接在tomcat共享一个数据源泉。
JNDI(Java Naming and Directory Interface,Java命名和目录接口)是一组在Java应用中访问命名和目录服务的API。命名服务将名称和对象联系起来,使得我们可以用名称访问对象。目录服务是一种命名服务,在这种服务里,对象不但有名称,还有属性。
(8) jdbcTemplate
通过上面的jdbc的学习,你是否发现了,在写数据库代码时,我们实现一点业务逻辑,但是重复写了很多数据库连接,关闭的样板式代码。这样我们我们完全可以对齐进行封装把重复代码封装起来,对外提供业务方法。在spring中,除了核心组件外,提供很多配套组件供我们使用,当然这些组件不是必须的,你可以选择搭配其他数据源,hibernate等。这里我们使用 spring提供的封装。必须引入spring-jdbc-xxx .jar spring-tx-xxxx.jar ,在spring3.0以后不建议在用jdbctemplate做基本的使用方案,jdk5.0以后增加了自动装箱等功能,建议采用simplejdbctemplate做为使用方案。便于对于bean操作的jdbcdaosupport迁移到simplejdbcdaosupport(方便直接获取simplejdbctemplate() 进行操作)上来,对于多参数等类的调用按照管理类推。
-
使用simplejdbcdaotemplate时注意配置文件对与你的dao类增加simplejdbctemplate索引
-
ApplicationContent.xml
<!-- jdbc 数据配置 -->
<bean id="datasource"
class="org.springframework.jdbc.datasource.DriverManagerDataSource">
<property name="driverClassName" value="com.mysql.jdbc.Driver" />
<!--注意一下&characterEncoding要修改为&characterEncoding-->
<property name="url" value="jdbc:mysql://localhost:3306/wsy_student?useUnicode=true&characterEncoding=utf-8"/>
<property name="username" value="root"/>
<property name="password" value="123456" />
</bean>
<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
<property name="dataSource" ref="datasource"></property>
</bean>
- 业务代码
public static void main(String[] args) {
ApplicationContext context = new ClassPathXmlApplicationContext("ApplicationContext.xml");
//这里转向你所在配置文件声明的bean
JdbcTemplate jdbc = (JdbcTemplate) context.getBean("jdbcTemplate");
SqlRowSet set = jdbc.queryForRowSet("select * from user");
while (set.next()) {
System.out.println(set.getInt(1)+" ");
System.out.print(set.getString("username"));
}
iService bean = context.getBean("jdk", iService.class);
Animal animal = (Animal) context.getBean("Animal");
animal.speak();
bean.selectDao();
//普通操作,样板式代码不见了,只出现了业务逻辑
}
- 当我们直接操作bean,使用业务更加清晰,spring为我们了rowmapper来做映射
- 实现RowMapper,并且对于自己的bean进行操作
package entiy;
import java.sql.ResultSet;
import java.sql.SQLException;
import org.springframework.jdbc.core.RowMapper;
/**
* @author DGW
* @date 2017 2017年6月1日 下午8:43:29
* @filename userMapper.java
* @TODO user的映射
*/
public class userMapper implements RowMapper<User>{
@Override
public User mapRow(ResultSet set, int arg1) throws SQLException {
User user=new User();
user.setUsername(set.getString("username"));
user.setPassword(set.getString("password"));
user.setQqnumber(set.getInt("qqnumber"));
user.setTime(set.getDate("time"));
return user;
}
}
- 拿取数据显得尤为精炼,看下面代码:
public class Main {
@SuppressWarnings("resource")
public static void main(String[] args) {
ApplicationContext context = new ClassPathXmlApplicationContext("ApplicationContext.xml");
JdbcTemplate jdbc = (JdbcTemplate) context.getBean("jdbcTemplate");
List<User> list = jdbc.query("select * from user", new userMapper());
for (User user : list) {
System.out.println(user);
}
/*SqlRowSet set = jdbc.queryForRowSet("select * from user");
while (set.next()) {
System.out.println(set.getInt(1)+" ");
System.out.print(set.getString("username"));
}
iService bean = context.getBean("jdk", iService.class);
Animal animal = (Animal) context.getBean("Animal");
animal.speak();
bean.selectDao();
//普通操作,样板式代码不见了,只出现了业务逻辑
*/ }
网友评论