网创优客建站品牌官网
为成都网站建设公司企业提供高品质网站建设
热线:028-86922220
成都专业网站建设公司

定制建站费用3500元

符合中小企业对网站设计、功能常规化式的企业展示型网站建设

成都品牌网站建设

品牌网站建设费用6000元

本套餐主要针对企业品牌型网站、中高端设计、前端互动体验...

成都商城网站建设

商城网站建设费用8000元

商城网站建设因基本功能的需求不同费用上面也有很大的差别...

成都微信网站建设

手机微信网站建站3000元

手机微信网站开发、微信官网、微信商城网站...

建站知识

当前位置:首页 > 建站知识

Java数据库常用操作

一、JDBC驱动

吉安网站制作公司哪家好,找成都创新互联公司!从网页设计、网站建设、微信开发、APP开发、响应式网站设计等网站项目制作,到程序开发,运营维护。成都创新互联公司公司2013年成立到现在10年的时间,我们拥有了丰富的建站经验和运维经验,来保证我们的工作的顺利进行。专注于网站建设就选成都创新互联公司

JDBC驱动的加载:

1、通过容器加载:

对于有容器的Java应用,可以直接将相应的驱动jar包放在容器的lib目录下,例如在Tomcat做容器的web应用,将驱动复制到tomcat的lib子目录下;

2、应用运行时加载:

如果希望应用自行加载相应的驱动,需要maven为应用打jar/war包时指定好搜寻驱动jar时的classpath,请参考:

https://maven.apache.org/shared/maven-archiver/examples/classpath.html

https://www.cnblogs.com/snaildev/p/8341610.html

示例一(可执行jar包下有lib目录存放依赖jar包):


        image
        
            
                org.apache.maven.plugins
                maven-jar-plugin
                2.4
                
                    
                        
                            true
                            lib/
                            some.package.MainClass
                        
                    
                
            
        
    

业务自行加载JDBC驱动时,需要在应用用JDBC之前执行如下操作加载驱动:

Class.forName("com.MySQL.jdbc.Driver");
// Then the following begin to use jdbc

二、通过连接池(DataSource的一种)管理与数据库的连接

目前常用的连接池为Druid或Hikari,分别说明如下:

1、Druid连接池:

maven依赖:


    com.alibaba
    druid
    1.1.11

示例代码:

DruidDataSource createSource(String name, String jdbcUrl, String userName, String password,
        maxActive, minIdle, maxWait, scanInterval, minActiveTime) {
    DruidDataSource src = DruidDataSource();
    src.setName(name);
    src.setUrl(jdbcUrl);
    src.setUsername(userName);
    src.setPassword(password);
    src.setDriverClassName(); 
    src.setInitialSize(minIdle);
    src.setMaxActive(maxActive);
    src.setMinIdle(minIdle);
    src.setMaxWait(maxWait); 
    src.setTimeBetweenEvictionRunsMillis(scanInterval); 
    src.setMinEvictableIdleTimeMillis(minActiveTime);   
    src.setTestWhileIdle(); 
    src.setTestOnBorrow();  
    src.setTestOnReturn();
    src.setPoolPreparedStatements(); 
    src.setMaxPoolPreparedStatementPerConnectionSize(); 
    src.setValidationQuery(); 
    src.setRemoveAbandoned(); 
    src.setRemoveAbandonedTimeout(); 
    src.setKeepAlive(); 
    if(!isDataSourceOk(src)){
        LOGGER.error("Data source "+ name + "test failed");
    }
    return src;
}
private static boolean isDataSourceOk(DataSource source){
    try (Connection connection = source.getConnection();
         PreparedStatement stmt = connection.prepareStatement("select 1");
         ResultSet resultSet = stmt.executeQuery()){
        resultSet.next();
        return true;
    }catch (Throwable e){
        return false;
    }
}

2、Hikari连接池

maven依赖:


    com.zaxxer
    HikariCP
    3.2.0

示例代码:

HikariDataSource createSource(String name, String jdbcUrl, String userName, String password,
        connectionTimeout, idleTimeout, maxLifeTime, poolSize) {
    HikariDataSource src = HikariDataSource();
    src.setPoolName(name);
    src.setJdbcUrl(jdbcUrl);
    src.setUsername(userName);
    src.setPassword(password);
    src.setDriverClassName(); 
    src.setConnectionTimeout(connectionTimeout);
    src.setIdleTimeout(idleTimeout); 
    src.setMaxLifetime(maxLifeTime); 
    src.setMaximumPoolSize(poolSize);
    if(!isDataSourceOk(src)){
        LOGGER.error("Data source "+ name + "test failed");
    }
    return src;
}

三、处理连接

1、首先通过连接池获取连接,例如:

try(Connection getConnection() SQLException {
    assert DataSourceManager.getDataSource() != null;
    return DataSourceManager.getDataSource().getConnection();
}

2、连接的SQL请求提交方式

从连接池(无轮DruidDataSource还是HirakiDataSource)申请到Connection对象拿到后,默认的提交方式为自动提交,即此时调用connection.getAutoCommit()返回的一定是true;

Connection对象归还连接池后,下次再从连接池申请一个Connection,默认的提交方式还是自动提交。需要清楚什时候用自动提交、什么时候适合手工提交。

概况起来就是,看申请到Connection对象到归还Connection对象这期间使用同一个Connection对象做了什么操作:

(1)只有读操作,没有任何写操作:用自动提交;

(2)只有一次对单个表的单条记录有进行写操作:用自动提交;

自动提交的代码示例如下

try(Connection connection = ()) {
    block.apply(connection); // Do all query or only one update for only one record
}

(3)对同一张表的多条记录进行了写操作,或者对不同表的记录分别进行了写操作:根据是否需要回滚、性能要求,确定是否需要支持事务性;如果要支持事物性,必须采用手动提交;

手动提交的操作示例:

try(Connection connection = ()) {
    boolean success = false;
    try{
        T t = block.apply(connection); // Use this connection process one transaction
        doCommit(connection);
        success = true;
        return t;
    }finally{
        if(!success) {
            doRollback(connection); // If possible, support rollback when failed
        }
    }
}

上述复杂过程的block中可能对connection的提交模式进行了修改,为了保持代码的兼容性,上述doCommit()及doRollback()的设计如下:

public static void doCommit(Connection connection) throws SQLException {
    if (!connection.getAutoCommit()) {
        connection.commit();
    }
}
private static void doRollback(Connection connection) throws SQLException {
    if (SUPPORT_ROLLBACK && !connection.getAutoCommit()) {
        connection.rollback();
    }
}

(4)耗时的操作,数据量比较大,这时依赖数据库的事物性及回滚已经没法达到;这种情况下应该分多次提交,并有应用层提供回滚;

示例如下:

try(Connection connection = ()) {
    boolean success = false;
    try{
        block1.accept(connection);
        doCommit(connection);
        block2.accept(connection);
        doCommit(connection);
        success = true;
    }finally{
        if(!success) {
            block2.clear(connection);
            block1.clear(connection);
        }
    }
}

新闻名称:Java数据库常用操作
文章URL:http://bjjierui.cn/article/jpipjj.html

其他资讯