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();
//普通操作，样板式代码不见了，只出现了业务逻辑
*/ }
