项目重构之数据源配置与优化：log4j 配置数据库连接池Druid，并实现日志存储到数据库一、前言二、准备知识四、结论及下载

泥瓦匠又和大家见面了，最近两天我在code review ，

顺便代码小小的refactoring（重构）下。先了解这个项目吧，这次解决的是数据源配置优化。因为这web项目中配置数据源的地方很多。例如

jdbc要配置数据源，mybatis要配置数据源，quartz定时任务要配置数据源，还有log4j存记录到数据库也要配置…

如题目，兴许大家的疑惑看了前面的说明会明白。这次给大家带来的数据源配置与优化：log4j 配置数据库连接池druid。

提纲：

二、准备知识

三、正文开始动手吧

、配置文件

、建数据表

、核心代码讲解

四、结论及下载

泥瓦匠也是怕自己说不清楚，又不想把log4j 和 durid介绍个遍。那样会太麻烦。这次主要是项目实战。所以泥瓦匠也不罗嗦知识准备这块也就是点到为止。

log4j 简介

在应用程序中添加日志记录总的来说基于三个目的：

监视代码中变量的变化情况，周期性的记录到文件中供其他应用进行统计分析工作；

跟踪代码运行时轨迹，作为日后审计的依据；

担当集成开发环境中的调试器的作用，向文件或控制台打印代码的调试信息。

它支持将日志信息输入到数据库，这次我们一mysql为例说明。我们需要log4j来将调试信息、操作信息等记录下来，以便后面的审计，这些日志信息包括用户id、用户姓名、操作类、路径、方法、操作时间、日志信息。

druid 简介

泥瓦匠的任务很简单，目的是为了数据源配置优化，实现数据源配置的唯一性。泥瓦匠也画了草图，曾经被人说成画图画出鬼画符的我告诉大家：没事，越做越好。如图，设计简单草图就是这样的。

项目重构之数据源配置与优化：log4j 配置数据库连接池Druid，并实现日志存储到数据库一、前言二、准备知识四、结论及下载

结论：一个项目的配置文件要保持唯一性，就是数据源配置的唯一性。

开始弄吧，为了写这个东西。我就也搞了个demo项目。泥瓦匠很辛苦的，哈哈送钱的上面支付宝哦。哈哈，泡了杯水，准备说这个项目了。下面，泥瓦匠先给出这个项目的结构图，这样我待会讲起来不怎么累。逻辑性比较强吧。如图：

上面很清楚的写着我需要完成的功能模块。最后那个test，是一个测试的servlet类。大家一看就明白。我先从配置文件说起吧。

配置文件：

dbconfig.properties 记录的是最基础的db配置：url name psd 等，代码如下：

<code>database.vendor = mysql</code>

<code>driverclassname= com.mysql.jdbc.driver</code>

<code>db_password = 123456</code>

<code>showsql= false</code>

<code>devmode = true</code>

<code>validationquery=select 1</code>

log4j.properties则是日志的配置，但日志的配置中有一点注意的是如下：

<code>log4j.rootlogger=debug,appender1</code>

<code>log4j.appender.appender1=org.apache.log4j.consoleappender</code>

<code>log4j.appender.appender1.layout=org.apache.log4j.ttcclayout</code>

<code>log4j.logger.test=info, db</code>

<code># log db setting</code>

<code>log4j.appender.db=org.nsg.dbsetting.myjdbcappender</code>

<code>log4j.appender.db.buffersize=1</code>

<code>log4j.appender.db.sql=insert into operate_log(handclass,method,createtime,loglevel,logmsg) values ('%c','%m','%d{yyyy-mm-dd hh\:mm\:ss}','%p','%m')</code>

<code>log4j.appender.db.layout=org.apache.log4j.patternlayout</code>

在这里，我们要注意两点：

一、设置我们包的下的logger权限，并给予存数据库的权限。

二、db的实现的应用要为你写的引用类。

建数据表：

然后我们要根据上面配置文件中写的数据库和表格我们要对应的建一个名为test的数据库和一张名为operate_log的表。

<code>navicat mysql data transfer</code>

<code>source server : mysql</code>

<code>source server version : 50617</code>

<code>source host : localhost:3307</code>

<code>source database : test</code>

<code>target server type : mysql</code>

<code>target server version : 50617</code>

<code>file encoding : 65001</code>

<code>set foreign_key_checks=0;</code>

<code>-- table structure for operate_log</code>

<code>drop table if exists `operate_log`;</code>

<code>create table `operate_log` (</code>

<code> </code><code>`log_id` int(11) not null auto_increment,</code>

<code> </code><code>`handclass` varchar(100) default null,</code>

<code> </code><code>`method` varchar(100) default null,</code>

<code> </code><code>`createtime` varchar(100) default null,</code>

<code> </code><code>`loglevel` varchar(20) default null,</code>

<code> </code><code>`logmsg` text,</code>

<code> </code><code>primary key (`log_id`)</code>

<code>) engine=innodb auto_increment=23 default charset=utf8;</code>

这样我们就可以开始写代码了，泥瓦匠是一个很细节的人。这次博客，我主要是讲下代码中的核心点。因为后面我会把项目提供给你们下载。所以，这里点到为止。

泥瓦匠说：点到为止，所谓师父领进门，修行在个人啊。

核心代码讲解：

myjdbcappender.java

用于log4j的数据库session管理[连接池用druid]。这个肯定是我们得核心思想。这里我就继承了log4j提供的

org.apache.log4j.jdbc.jdbcappender;然后只要简单的重写了closeconnection和

getconnection方法。如果获取druid数据库源对象异常的话，我还写了个取消初始化

的方法uninitialize。代码这边也贴出下，方便大家观看：

100

101

102

103

104

105

106

107

<code>package org.nsg.dbsetting;</code>

<code>import java.sql.connection;</code>

<code>import java.sql.sqlexception;</code>

<code>import java.util.properties;</code>

<code>import org.apache.log4j.jdbc.jdbcappender;</code>

<code>import org.apache.log4j.spi.errorcode;</code>

<code>import org.nsg.constant.propertiesconst;</code>

<code>import org.nsg.exception.jdbcexception;</code>

<code>import org.nsg.util.myproperties;</code>

<code>import org.nsg.util.propertiesutil;</code>

<code>import com.alibaba.druid.pool.druiddatasource;</code>

<code>import com.alibaba.druid.pool.druiddatasourcefactory;</code>

<code> </code><code>* @description myjdbcappender.java</code>

<code> </code><code>* 用于log4j的数据库session管理[连接池用druid]</code>

<code> </code><code>* @author 泥沙砖瓦浆木匠</code>

<code> </code><code>* @version 1.0</code>

<code>public class myjdbcappender extends jdbcappender</code>

<code> </code><code>/* druid数据源 */</code>

<code> </code><code>private druiddatasource datasource;</code>

<code> </code><code>public myjdbcappender()</code>

<code> </code><code>super();</code>

<code> </code><code>@override</code>

<code> </code><code>protected void closeconnection(connection con)</code>

<code> </code><code>/* 如果数据库连接对象不为空和没有被关闭的话，关闭数据库连接 */</code>

<code> </code><code>if ( con != null && !con.isclosed())</code>

<code> </code><code>con.close();</code>

<code> </code><code>catch (sqlexception e)</code>

<code> </code><code>errorhandler.error("error closing myjdbcappender.closeconnection() 's connection",e,errorcode.generic_failure);</code>

<code> </code><code>protected connection getconnection() throws sqlexception</code>

<code> </code><code>/* 获取数据库配置property */</code>

<code> </code><code>myproperties properties = propertiesutil.loadpropertyfile(propertiesconst.db_config);</code>

<code> </code><code>string classname = string.valueof(properties.getproperty("driverclassname",""));</code>

<code> </code><code>string connurl = string.valueof(properties.getproperty("db_url",""));</code>

<code> </code><code>string uname = string.valueof(properties.getproperty("db_user",""));</code>

<code> </code><code>string psw = string.valueof(properties.getproperty("db_password",""));</code>

<code> </code><code>system.out.println(classname);</code>

<code> </code><code>system.out.println(connurl);</code>

<code> </code><code>system.out.println(uname);</code>

<code> </code><code>system.out.println(psw);</code>

<code> </code><code>properties result = new properties();</code>

<code> </code><code>result.put("driverclassname",classname);</code>

<code> </code><code>result.put("url",connurl);</code>

<code> </code><code>result.put("username",uname);</code>

<code> </code><code>result.put("password",psw);</code>

<code> </code><code>/* 其他配置自然你也可以自己写property 然后获取set */</code>

<code> </code><code>result.put("maxactive","30");</code>

<code> </code><code>result.put("minidle","3");</code>

<code> </code><code>datasource = (druiddatasource) druiddatasourcefactory.createdatasource(result);</code>

<code> </code><code>catch (exception e)</code>

<code> </code><code>/* druid数据库源对象产生失败后，取消初始化 */</code>

<code> </code><code>try {uninitialize();} catch(exception e2) {}</code>

<code> </code><code>throw new jdbcexception(e);</code>

<code> </code><code>return datasource.getconnection();</code>

<code> </code><code>/* 取消初始化 */</code>

<code> </code><code>public void uninitialize()</code>

<code> </code><code>if (datasource != null)</code>

<code> </code><code>datasource.close();</code>

<code> </code><code>throw new jdbcexception(string.format("myjdbcappender uninitialize fail (%s)",e));</code>

<code> </code><code>finally</code>

<code> </code><code>super.close();</code>

值得注意的一点是，泥瓦匠为了方便，所以在其中的地方没有获取druid连接池的配置。而是直接写了下面：

<code>/* 其他配置自然你也可以自己写property 然后获取set */</code>

其实这样写是不好了，我们可以写一个druid.properties然后将连接池的配置放入其中。获取set，for循环set即可。这边我就不实现了。很简单哦，泥瓦匠相信你们。

最后我演示下，示例代码：放到tomcat7上，然后运行访问

看到控制台刷出来两条信息，因为我门设置的是log4j.logger.test=info, db。

然后我们去查看数据库，这边我用navicat：

结论：重构很有意思，慢慢来，一点一点来，就行了。细节成就未来。

项目重构之数据源配置与优化：log4j 配置数据库连接池Druid，并实现日志存储到数据库一、前言二、准备知识四、结论及下载

继续阅读

Java String.format方法的简单使用

neo4j之cypher使用文档

GitHub连夜封杀！这份阿里 10W 字内部 Java 字面试手册到底有多强？

spark/scala关于【资源文件】加载方法概述外部文件加载方案测试资源文件打包入jar包中小结

NOSQL安全攻击

mybatis_入门程序Mybatis入门

mysql使用source命令导入.sql文件

AOP编程_Android优雅权限框架(1)概念基础，2021金三银四前言正文大纲正文

登录plsql 报错 the account is locked --用户被锁

Effective Java 8:通用程序设计

SequoiaDB巨杉数据库C++驱动概述

OOM三种类型

工厂模式-三种类型

【递归】高效率求2的n次幂

win10本地scala和spark安装安装scala安装spark

scala (3) Function 和 Method

项目重构之数据源配置与优化：log4j 配置数据库连接池Druid，并实现日志存储到数据库一、 前言二、准备知识四、结论及下载

继续阅读

项目重构之数据源配置与优化：log4j 配置数据库连接池Druid，并实现日志存储到数据库一、前言二、准备知识四、结论及下载