浅析JDBC的使用方法
1.使用步骤:
- 导包
- 加载驱动类class.forName(....)
- DriverManager获取sql对象
- 写sql语句
- Statement与prepareStatement不一样的执行sql语句,前者是直接sql对象.执行语句,而后者是预处理,即在创建sql对象时,就用sql语句,最后在用对象执行操作。
2.JDBCUtils工具类:
就是把使用步骤的共性,提出来,放在一个类中,这样以后就能直接调用创建sql对象的方法就行了。
值得一提的是,如果我们使用配置文件,扩展性更好,在使用其他数据库时,我们只需要更改配置文件properties。获取配置文件可以使用properties对象。获取jar包的绝对路径可以使用classLoader类加载器。这样我们就不用自己添加路径了。
publicclassJDBCUtils{
privatestaticStringurl;
privatestaticStringuser;
privatestaticStringpassword;
privatestaticStringdriver;
/**
*文件的读取,只需要读取一次即可拿到这些值。使用静态代码块
*/
static{
//读取资源文件,获取值。
try{
//1.创建Properties集合类。
Propertiespro=newProperties();
//获取src路径下的文件的方式--->ClassLoader类加载器
ClassLoaderclassLoader=JDBCUtils.class.getClassLoader();
URLres=classLoader.getResource("jdbc.properties");
Stringpath=res.getPath();
//2.加载文件
pro.load(newFileReader(path));
//3.获取数据,赋值
url=pro.getProperty("url");
user=pro.getProperty("user");
password=pro.getProperty("password");
driver=pro.getProperty("driver");
//4.注册驱动
Class.forName(driver);
}catch(IOExceptione){
e.printStackTrace();
}catch(ClassNotFoundExceptione){
e.printStackTrace();
}
}
/**
*获取连接
*@return连接对象
*/
publicstaticConnectiongetConnection()throwsSQLException{
returnDriverManager.getConnection(url,user,password);
}
/**
*释放资源
*@paramstmt
*@paramconn
*/
publicstaticvoidclose(Statementstmt,Connectionconn){
if(stmt!=null){
try{
stmt.close();
}catch(SQLExceptione){
e.printStackTrace();
}
}
if(conn!=null){
try{
conn.close();
}catch(SQLExceptione){
e.printStackTrace();
}
}
}
/**
*释放资源
*@paramstmt
*@paramconn
*/
publicstaticvoidclose(ResultSetrs,Statementstmt,Connectionconn){
if(rs!=null){
try{
rs.close();
}catch(SQLExceptione){
e.printStackTrace();
}
}
if(stmt!=null){
try{
stmt.close();
}catch(SQLExceptione){
e.printStackTrace();
}
}
if(conn!=null){
try{
conn.close();
}catch(SQLExceptione){
e.printStackTrace();
}
}
}
}
3.DBC控制事务:
在执行sql语句时,如果程序执行过程中,发生了异常。比如有两个sql语句,一个是转账操作,一个人存转的这笔钱,如果第一个操作结束后发生了异常。那么这笔钱就会不翼而飞,所以为了避免这样的情况,可以使用事务。
具体操作
- 开启事务:setAutoCommit(booleanautoCommit):调用该方法设置参数为false,即开启事务。
- 提交事务:commit()当所有sql都执行完提交事务。
- 回滚事务:rollback()在catch中回滚事务。
publicstaticvoidmain(String[]args){
PreparedStatementpstmt1=null;
PreparedStatementpstmt2=null;
Connectioncon=null;
try{
con=JDBCUtils.getConnection();
//开启事务
con.setAutoCommit(false);
//2.1张三-500
Stringsql1="updateaccountsetbalance=balance-?whereid=?";
//2.2李四+500
Stringsql2="updateaccountsetbalance=balance+?whereid=?";
pstmt1=con.prepareStatement(sql1);
pstmt2=con.prepareStatement(sql2);
//4.设置参数,sql语句里的问号
pstmt1.setDouble(1,500);//填第一个数据
pstmt1.setInt(2,1);//填第二个数据
pstmt2.setDouble(1,500);
pstmt2.setInt(2,2);
//5.执行sql
pstmt1.executeUpdate();
//手动制造异常
inti=3/0;
pstmt2.executeUpdate();
//提交事务
con.commit();
}catch(SQLExceptione){
e.printStackTrace();
}catch(Exceptione){
try{
con.rollback();
}catch(SQLExceptionex){
ex.printStackTrace();
}
}finally{
JDBCUtils.close(con,pstmt1);
JDBCUtils.close(con,pstmt2);
}
}
4.JDBC连接池
连接池,就是先创建好一些连接对象,要用的的时候,直接使用,提高了效率,用完之后,归还给连接池,以便其他的使用。
c3p0连接池:
1.步骤:
导入jar包(两个)c3p0-0.9.5.2.jarmchange-commons-java-0.2.12.jar,还需要导入数据库驱动jar包
2.定义配置文件:
名称:c3p0.properties或者c3p0-config.xml。
路径:直接将文件放在src目录下即可。
3.创建核心对象数据库连接池对象ComboPooledDataSource
4.获取连接:getConnection
代码:
//1.创建数据库连接池对象 DataSourceds=newComboPooledDataSource(); //2.获取连接对象 Connectionconn=ds.getConnection();
druid:
这个是阿里的,性能更好,效率更高。
1.步骤:
导入jar包druid-1.0.9.jar
2.定义配置文件:
是properties形式的
可以叫任意名称,可以放在任意目录下
3.加载配置文件。Properties
4.获取数据库连接池对象:通过工厂类来获取DruidDataSourceFactory
5.获取连接:getConnection
//3.加载配置文件
Propertiespro=newProperties();
InputStreamis=DruidDemo.class.getClassLoader().getResourceAsStream("druid.properties");
pro.load(is);
//4.获取连接池对象
DataSourceds=DruidDataSourceFactory.createDataSource(pro);
//5.获取连接
Connectionconn=ds.getConnection();
由于代码还是冗长,重复率高,所以可以自定义个工具类:
publicclassJDBCUtils{
//1.定义成员变量DataSource
privatestaticDataSourceds;
static{
try{
//1.加载配置文件
Propertiespro=newProperties();
pro.load(JDBCUtils.class.getClassLoader().getResourceAsStream("druid.properties"));
//2.获取DataSource
ds=DruidDataSourceFactory.createDataSource(pro);
}catch(IOExceptione){
e.printStackTrace();
}catch(Exceptione){
e.printStackTrace();
}
}
/**
*获取连接
*/
publicstaticConnectiongetConnection()throwsSQLException{
returnds.getConnection();
}
SpringJDBC
Spring框架对JDBC的简单封装。提供了一个JDBCTemplate对象简化JDBC的开发
1.步骤:
导入jar包
创建JdbcTemplate对象。依赖于数据源DataSource
JdbcTemplatetemplate=newJdbcTemplate(ds);
2.调用JdbcTemplate的方法来完成CRUD的操作
update():执行DML语句。增、删、改语句
queryForMap():查询结果将结果集封装为map集合,将列名作为key,将值作为value将这条记录封装为一个map集合
注意:这个方法查询的结果集长度只能是1
queryForList():查询结果将结果集封装为list集合
注意:将每一条记录封装为一个Map集合,再将Map集合装载到List集合中
query():查询结果,将结果封装为JavaBean对象
query的参数:RowMapper
一般我们使用BeanPropertyRowMapper实现类。可以完成数据到JavaBean的自动封装
newBeanPropertyRowMapper<类型>(类型.class)
queryForObject:查询结果,将结果封装为对象
一般用于聚合函数的查询
//2.定义sql //1.获取JDBCTemplate对象 privateJdbcTemplatetemplate=newJdbcTemplate(JDBCUtils.getDataSource()); Stringsql="updateempsetsalary=10000whereid=1001"; //3.执行sql intcount=template.update(sql); System.out.println(count);
这大大简化了我们curd的代码量。
以上就是浅析JDBC的使用方法的详细内容,更多关于Javajdbc使用的资料请关注毛票票其它相关文章!
声明:本文内容来源于网络,版权归原作者所有,内容由互联网用户自发贡献自行上传,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任。如果您发现有涉嫌版权的内容,欢迎发送邮件至:czq8825#qq.com(发邮件时,请将#更换为@)进行举报,并提供相关证据,一经查实,本站将立刻删除涉嫌侵权内容。