学习笔记-jdbc

批量插入数据

public void test() throws Exception{Connection connection= JDBCUtils.getConnection();String sql="insert into test(name) values(?)";PreparedStatement ps = connection.prepareStatement(sql);//设置自动提交为false，等最后一起提交connection.setAutoCommit(false);for (int i=0;i<=10000;i++){ps.setString(1,"name"+i);//要使用批量插入需要在连接数据库的url地址中加入一个属性//rewriteBatchedStatements=true//将sql语句添加到Batchps.addBatch();//此处的判断根据实际情况if (i%500==0){//执行batchps.executeBatch();//清空batch，清除之前已经执行的sqlps.clearBatch();}}//最后统一提交connection.commit();JDBCUtils.closeResource(connection,ps);}

大量数据插入时，使用批量插入可以减少很多时间

数据库插入图片等二进制文件

public class BlobTest {//向数据表插入blob字段@Testpublic void test() throws Exception {Connection connection= JDBCUtils.getConnection();String sql="insert into customers(name,email,birth,photo) values(?,?,?,?)";PreparedStatement ps = connection.prepareStatement(sql);ps.setObject(1,"坤坤");ps.setObject(2,"zhang@qq.com");ps.setObject(3,"1992-09-08");//路径是存放文件的路径File file=new File("tupian.jpg");InputStream inputStream=new FileInputStream(file);ps.setBlob(4,inputStream);ps.execute();JDBCUtils.closeResource(connection,ps);}//查询customers中的blob字段@Testpublic void testBlob() throws Exception{Connection connection= JDBCUtils.getConnection();String sql="select photo from customers where id=?";PreparedStatement ps = connection.prepareStatement(sql);ps.setInt(1,20);ResultSet resultSet = ps.executeQuery();if (resultSet.next()) {//blob字段下载下来以文件方式保存本地Blob blob = resultSet.getBlob(1);InputStream binaryStream = blob.getBinaryStream();FileOutputStream fileOutputStream=new FileOutputStream("maomi.jpg");byte[] bytes=new byte[1024];int len;while ((len=binaryStream.read(bytes))!=-1){fileOutputStream.write(bytes,0,len);}if (binaryStream!=null){binaryStream.close();}if (fileOutputStream!=null){fileOutputStream.close();}}JDBCUtils.closeResource(connection,ps,resultSet);}
}

并不建议将二进制文件传入数据库，这样会耗费大量时间，可以将图片保存到服务器，数据库存储保存路径，通过保存路径获取需要的图片资源

sql事务

事务的ACID属性

• 原子性(Atomicity):原子性是指事务是一个不可分割的工作单位，事务中的操作要么都发生要么都不发生
• 一致性(Consistency):事务必须使数据库从一个一致性状态变换到另外一个一致性状态
• 隔离性(Isolation):事务的隔离性是指一个事务的执行不能被其他事务干扰，即一个事务内部的操作及使用的数据对并发的其他事务是隔离的，并发执行的各个事物之间不能相互干扰
• 持久性(Durability):持久性是指一个事务一旦被提交，他对数据库中数据的改变就是永久性的，接下来的其他操作和数据库故障不应该对其有任何影响

connection.setTransactionIsolation(Connection.TRANSACTION_READ_COMMITTED);//设置数据库隔离级别
READ_UNCOMMITTED
READ_COMMITTED
REPEATABLE_READ
SERIALIZABLE(串列化)

public void test() {Connection connection=null;try {connection= JDBCUtils.getConnection();//自动提交为falseconnection.setAutoCommit(false);String sql="update user_table set balance=balance-100 where user=?";updateTest(connection,sql,"AA");//System.out.println(10/0);String sql2="update user_table set balance=balance+100 where user=?";updateTest(connection,sql2,"BB");//如果没有错误提交数据connection.commit();}catch (Exception e){try {//报错之后进行事务的回滚，必须回滚，虽然设置自动提交为false但是数据库连接关闭时还是会提交connection.rollback();} catch (SQLException sqlException) {sqlException.printStackTrace();}e.printStackTrace();}finally {try {//修改其为自动提交数据，主要针对于使用数据库连接池使用//设置连接为false之后需要将自动提交设置回来，因为如果是连接池的话连接是重复使用的connection.setAutoCommit(true);} catch (SQLException sqlException) {sqlException.printStackTrace();}JDBCUtils.closeResource(connection,null);}}

1.什么叫数据库事务
事务：一组逻辑操作单元，使数据从一种状态变换到另一种状态
一组逻辑操作单元：一个或多个dml操作

2.事务处理原则：保证所有事物都作为一个工作单元来执行，即使出现故障都不能改变这种执行方式。 当在一个事务中执行多个操作时，要么所有的事务都被提交（commit），那么这些修改就永久的保存下来 , 要么数据库管理系统将放弃所有的修改，整个事务回滚（rollback）到最初状态

3.数据一旦提交不可回滚
>DML默认情况下操作一旦执行，都会自动提交
setAutoCommit=false的方式取消DML自动提交
>默认在关闭连接时，会自动提交数据

数据库连接池技术

数据库连接池（Database Connection Pooling）在程序初始化时创建一定数量的数据库连接对象并将其保存在一块内存区中，它允许应用程序重复使用一个现有的数据库连接，而不是重新建立一个；释放空闲时间超过最大空闲时间的数据库连接以避免因为没有释放数据库连接而引起的数据库连接遗漏。
即在程序初始化的时候创建一定数量的数据库连接，用完可以放回去，下一个在接着用，通过配置连接池的参数来控制连接池中的初始连接数、最小连接、最大连接、最大空闲时间这些参数保证访问数据库的数量在一定可控制的范围类，防止系统崩溃，使用户的体验好。

c3p0

c3p0需要配置xml文件

com.mysql.jdbc.Driverjdbc:mysql:///test?characterEncoding=utf8root12351010100502

public class C3P0 {//数据库连接池只提供一个即可private static ComboPooledDataSource cpds=new ComboPooledDataSource("hellc3p0");@Testpublic void c3p0Test() throws PropertyVetoException, SQLException {ComboPooledDataSource cpds = new ComboPooledDataSource();//配置可以在xml文件中配置，也可以在java代码中配置cpds.setDriverClass( "com.mysql.jdbc.Driver" ); //loads the jdbc drivercpds.setJdbcUrl( "jdbc:mysql://localhost:3306/test?characterEncoding=utf8&useSSL=false&serverTimezone=UTC" );cpds.setUser("root");cpds.setPassword("zhanghao123");//通过设置相关的参数，对数据库连接池进行管理//设置初始时数据库连接池中的连接数cpds.setInitialPoolSize(10);//获取连接池中的连接Connection conn=cpds.getConnection();System.out.println(conn);//销毁数据库连接池//DataSources.destroy(cpds);}
}

dbcp

dbcp配置properties文件，此处就不再写，其他配置可自行查阅

//dbcp.properties
driverClassName=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/test?characterEncoding=utf8
username=root
password=123
//初始化连接个数
initialSize=10

public class Dbcp {//dbcp数据库连接池技术//使用配置文件连接数据库private static DataSource dataSource;static {Properties pros=new Properties();InputStream dbcpIn = ClassLoader.getSystemClassLoader().getResourceAsStream("dbcp.properties");try {pros.load(dbcpIn);} catch (IOException e) {e.printStackTrace();}try {dataSource = BasicDataSourceFactory.createDataSource(pros);} catch (Exception e) {e.printStackTrace();}}public void getDBCPConnection() throws SQLException {//任何一个连接池都有DataSource的实现类//创建了dbcp的数据库连接池BasicDataSource source=new BasicDataSource();//设置基本信息source.setDriverClassName("com.mysql.jdbc.Driver");source.setUrl("jdbc:mysql:///test?characterEncoding=utf8");source.setUsername("root");source.setPassword("zhanghao123");//还可以设置其他涉及数据库连接池管理的相关属性source.setInitialSize(10);source.setMaxActive(10);Connection connection = source.getConnection();System.out.println(connection);}
}

druid

druid配置properties文件

url=jdbc:mysql://localhost:3306/test?characterEncoding=utf8
username=root
password=123
driverClassName=com.mysql.jdbc.DriverinitialSize=10
maxActive=10

public class DruidTest {private static DataSource dataSource;static {Properties pros=new Properties();try {FileInputStream fileInputStream=new FileInputStream(new File("src/druid.properties"));pros.load(fileInputStream);dataSource = DruidDataSourceFactory.createDataSource(pros);} catch (Exception e) {e.printStackTrace();}}@Testpublic void test() throws Exception {Connection connection = dataSource.getConnection();System.out.println(connection);}
}

jdbc工具apach

apach提供的api就是封装好的与数据库交互的一些工具类，就像上面写好的一些封装方法

来看看怎么使用

public class QueryRunnerTest {@Testpublic void testInsert() throws Exception {QueryRunner runner=new QueryRunner();Connection connection = JDBCUtils.getConnection();String sql="insert into customers(name,email,birth) values(?,?,?)";int insertCount = runner.update(connection, sql, "蔡徐坤", "caixukun@126.com", "1997-01-09");System.out.println(insertCount);JDBCUtils.closeResource(connection,null);}//queryRunner查询//BeanHandler：是ResultSetHandler接口的实现类，用于封装表中的一条记录@Testpublic void testQ() throws Exception {QueryRunner runner=new QueryRunner();Connection connection = JDBCUtils.getConnection();String sql="select id,name,email,birth from customers where id=?";BeanHandler handler=new BeanHandler(Customer.class);Customer query = runner.query(connection, sql, handler, 21);System.out.println(query);JDBCUtils.closeResource(connection,null);}//BeanListHandler：是ResultSetHandler接口的实现类，用于封装表中的多条记录@Testpublic void testQ2() throws Exception {QueryRunner runner=new QueryRunner();Connection connection = JDBCUtils.getConnection();String sql="select id,name,email,birth from customers where id handler=new BeanListHandler(Customer.class);List query = runner.query(connection, sql, handler, 21);System.out.println(query);JDBCUtils.closeResource(connection,null);}//ScalarHandler：是ResultSetHandler接口的实现类，用于查询特殊值@Testpublic void testScalar() throws Exception {QueryRunner runner=new QueryRunner();Connection connection = JDBCUtils.getConnection();String sql="select count(*) from customers";ScalarHandler handler=new ScalarHandler();Object query = runner.query(connection, sql, handler);System.out.println(query);dbClose(connection,null,null);//JDBCUtils.closeResource(connection,null);}//使用dbutils.jar中提供的DbUtils工具类，实现资源关闭public void dbClose(Connection conn, Statement ps, ResultSet rs) {try {DbUtils.close(conn);} catch (SQLException sqlException) {sqlException.printStackTrace();}try {DbUtils.close(rs);} catch (SQLException sqlException) {sqlException.printStackTrace();}try {DbUtils.close(ps);} catch (SQLException sqlException) {sqlException.printStackTrace();}}
}

其中获取连接还是需要自己的工具类获取连接，因为你的数据库只有你知道是什么名字和密码

初学者，可能有些地方的总结或者代码有错误，谅解

本文来自互联网用户投稿，文章观点仅代表作者本人，不代表本站立场，不承担相关法律责任。如若转载，请注明出处。 如若内容造成侵权/违法违规/事实不符，请点击【内容举报】进行投诉反馈！