让JDBC查询日志变得简单

    JDBC java.sql.PreparedStatement接口的简单扩展可以使查询日志更少犯错,同时整理您的代码。在本文中,IBM电子商务顾问Jens Wyke向您介绍如何应用基本的封装技术(“通过封装来实现扩展”也称为Decorator设计模式)来获得最满意的结果。

  在大多数情况下,JDBC PreparedStatements 使执行数据库查询更简便并可以显著提升您整体应用程序的性能。当谈到日志查询语句时PreparedStatement接口就显得有些不足了。PreparedStatement的优势在于其可变性,但是一个好的日志条目必须正确描述如何将SQL发送到数据库,它将密切关注用实际的参数值来替换所有参数占位符。虽然有多种方法可以解决这一难题,但没有任何一种易于大规模实施并且大部分将扰乱您的程序代码。

   在本文中,您将了解到如何扩展JDBC PreparedStatement接口来进行查询日志。LoggableStatement类实现PreparedStatement接口,但添加用于获得查询字符串的方法,使用一种适用于记录的格式。使用LoggableStatement类可以减少日志代码中发生错误的几率,生成简单且易于管理的代码。

  注意:本文假设您有丰富的JDBC和PreparedStatement类经验。

  典型日志解决方案  

  表1介绍了数据库查询时通常是如何使用PreparedStatement(虽然忽略了初始化和错误处理)。在本文中,我们将使用SQL query SELECT做为例子,但讨论使用其它类型的SQL语句,如DELETE、UPDATE和INSERT。

  表1:一个典型的SQL数据库查询

String sql = "select foo, bar from foobar where foo < ? and bar = ?"; String fooValue = new Long(99); String barValue = "christmas"; Connection conn = dataSource.getConnection(); PreparedStatement pstmt = conn.prepareStatement(sql); pstmt.setLong(1,fooValue); pstmt.setString(2,barValue); ResultSet rs = pstmt.executeQuery(); // parse result...

  表1中一个好的查询日志条目看起来应与下面有几分类似:

Executing query: select foo,bar from foobar where foo < 99 and bar='christmas'

  下面是查询的日志代码的一个例子。注意:表1中的问号已经被每个参数的值替换。

System.out.println("Executing query:  select foo, bar from foobar where foo< "+fooValue+" and bar = '+barValue+"'")

  一种更好的方法是创建方法,我们称之为replaceFirstQuestionMark,它读取查询字符串并用参数值替换问号,如表2所示。这类方法的使用无需创建复制的字符串来描述SQL语句。

  表 2:使用replaceFirstQuestionMark来进行字符串替换

// listing 1 goes here sql = replaceFirstQuestionMark(sql, fooValue); sql = replaceFirstQuestionMark(sql, barValue); System.out.println("Executing query: "+sql);

  虽然这些解决方案都易于实施,但没有一种是完美的。问题是在更改SQL模板的同时也必须更改日志代码。您将在某一点上犯错几乎是不可避免的。查询将更改但您忘记了更新日志代码,您将结束与将发送到数据库的查询不匹配的日志条目 -- 调试恶梦。

  我们真正需要的是一种使我们能够一次性使用每个参数变量(在我们的实例中为fooValue和barValue)的设计方案。我们希望有一种方法,它使我们能够获得查询字符串,并用实际的参数值替换参数占位符。由于java.sql.PreparedStatement没有此类方法,我们必须自己实现。

  定制解决方案

  我们的PreparedStatement定制实施将做为围绕JDBC驱动器提供的“真实语句(real statement)”的封装器(Wrapper)。封装器语句将转发所有方法调用(例如setLong(int, long)和setString(int,String)) 到“真实语句”。在这样做之前它将保存相关的参数值,从而它们可以用于生成日志输出结果。

  表3介绍了LoggableStatement类如何实现java.sql.PreparedStatement,以及它如何使用JDBC连接和SQL模板作为输入来构建。

  表3:LoggableStatement实现java.sql.PreparedStatement

public class LoggableStatement implements java.sql.PreparedStatement { // used for storing parameter values needed // for producing log private ArrayList parameterValues; // the query string with question marks as // parameter placeholders private String sqlTemplate; // a statement created from a real database // connection private PreparedStatement wrappedStatement; public LoggableStatement(Connection connection, String sql) throws SQLException { // use connection to make a prepared statement wrappedStatement = connection.prepareStatement(sql); sqlTemplate = sql; parameterValues = new ArrayList(); } }

  LoggableStatement如何工作

  表4介绍了LoggableStatement如何向saveQueryParamValue()方法添加一个调用,以及在方法setLong和setString的“真实语句”上调用相应的方法。我们采用与用于参数设置的所有方法(例如setChar、setLong、setRef和setObj)相同的方式来增加saveQueryParamValue()调用。表4还显示了在不调用saveQueryParamValue()的情况下如何封装方法executeQuery,因为它不是一个“参数设置”方法。

  表4:LoggableStatement 方法

public void setLong(int parameterIndex, long x) throws java.sql.SQLException { wrappedStatement.setLong(parameterIndex, x); saveQueryParamValue(parameterIndex, new Long(x)); } public void setString(int parameterIndex, String x) throws java.sql.SQLException { wrappedStatement.setString(parameterIndex, x); saveQueryParamValue(parameterIndex, x); } public ResultSet executeQuery() throws java.sql.SQLException { return wrappedStatement.executeQuery(); }

  表5中显示了saveQueryParamValue()方法。它把每个参数值转换成String表示,保存以便getQueryString方法日后使用。缺省情况下,一个对象使用其 toString方法将被转换成String,但如果对象是String或Date,它将用单引号('')表示。getQueryString()方法使您能够从日志复制大多数查询并进行粘贴,无需修改交互式SQL处理器就可进行测试和调试。您可以根据需要修订该方法来转换其它类的参数值。

  表5:saveQueryParamValue()方法

private void saveQueryParamValue(int position, Object obj) { String strValue; if (obj instanceof String || obj instanceof Date) { // if we have a String, include '' in the saved value strValue = "'" + obj + "'"; } else { if (obj == null) { // convert null to the string null strValue = "null"; } else { // unknown object (includes all Numbers), just call toString strValue = obj.toString(); } } // if we are setting a position larger than current size of // parameterValues, first make it larger while (position >= parameterValues.size()) { parameterValues.add(null); } // save the parameter parameterValues.set(position, strValue); }

  当我们使用标准方法来设置所有参数时,我们在LoggableStatement中简单调用getQueryString()方法来获得查询字符串。所有问号都将被真正的参数值替换,它准备输出到我们选定的日志目的地。

  使用LoggableStatement

  表6显示如何更改表1和表2中的代码来使用 LoggableStatement。将LoggableStatement引入到我们的应用程序代码中可以解决复制的参数变量问题。如果改变了SQL模板,我们只需更新PreparedStatement上的参数设置调用(例如添加一个pstmt.setString(3,"new-param-value"))。这一更改将在日志输出结果中反映出,无需任何记录代码的手工更新。

  表6:使用LoggableStatement

  
String sql = "select foo, bar from foobar where foo < ? and bar = ?"; long fooValue = 99; String barValue = "christmas"; Connection conn = dataSource.getConnection(); PreparedStatement pstmt; if(logEnabled) // use a switch to toggle logging. pstmt = new LoggableStatement(conn,sql); else pstmt = conn.prepareStatement(sql); pstmt.setLong(1,fooValue); pstmt.setString(2,barValue); if(logEnabled) System.out.println("Executing query: "+ ((LoggableStatement)pstmt).getQueryString()); ResultSet rs = pstmt.executeQuery();

  结束语

  使用本文介绍的非常简单的步骤,您可以为查询记录扩展JDBC PreparedStatement接口。我们在此处使用的技术可以被视为“通过封装来实现扩展”,或作为Decorator设计模式的一个实例(见参考资料)。通过封装来实现扩展在当您必须扩展API但subclassing不是一项可选功能时极其有用。

  您将在参考资料部分找到LoggableStatement类的源代码。您可以按原样使用它,或者进行定制以满足您的数据库应用程序的特殊需求。

  参考资料

  ◆ 下载LoggableStatement类的源代码 。

  ◆ 您将在Roman Vichr的提示和技巧:JDBC 提示 (developerWorks, 2002年10月)中找到使用PreparedStatements的简要介绍.

  ◆ Lennart Jorelid的“Use JDBC for industrial-strength performance ”(developerWorks,2000年1月)是一篇不错的在JDBC中设计模式的两部分介绍性文章。

  ◆ Josh Heidebrecht撰写的“JDBC 3.0新特性 ”(developerWorks,2001年7月)提供JDBC 3.0的概述。

  ◆ 您可以从java.sun.com 下载Java platform, Standard Edition和JDBC 3.0 API规范。

  ◆ David Gallardo的“Java设计模式101 ”(developerWorks,2002年1月)是Gang of Four模板不错的介绍。

  ◆ Paul Monday的“ Java设计模式 201”(developerWorks,2002年4月)为高级学员提供了Java设计模式更具概念性的说明。

  ◆ Vince Huston的 Design Patterns site 是另外一个了解设计模式不错的资源。

  ◆ Brian Goetz的“Java 理论与实践:性能管理 — 您有规划吗? ” (developerWorks,2003年3月)阐述了一些您可以实施用来提升Java应用程序整体性能的措施。

时间: 2025-01-15 20:48:58

让JDBC查询日志变得简单的相关文章

手把手教你完成MaxCompute JDBC自定义日志配置

注:MaxCompute原名ODPS,是阿里云自研的大数据计算平台,文中出现的MaxCompute与ODPS都指代同一平台,不做区分 与MaxCompute JDBC相关的日志有两种,一种是由JDBC内部代码直接输出的日志,第二种是JDBC抛出异常后,由调用JDBC API的宿主应用捕获后输出的.由于第二类日志取决于宿主应用如何处理异常及如何配置日志体系,所以本文主要讨论的对象是第一种日志. 在2.0-beta之前,MaxCompute JDBC的日志只会输出到命令行终端(标准输出流),它底层使

MySQL源码学习:关于慢查询日志中的Rows_examined=0

最近在一个项目中DBA同学问了一个问题:为什么很多慢查询日志中显示 Rows_examined : 0? 需要说明的是, 这类慢查询语句都是类似 select count(*) from (-)t; 在说明这个问题之前,我们先指出两个相关背景: 1.MySQL的临时表,都是MyISAM的. 2.MyISAM表中的记录总数是额外存储的,count(*)的时候不需要遍历数据. 3.把count(*)转换为取一个const值这件事情,是在优化(optimize)阶段作的. 问题分析: 这个值对应于代码

使用jdbc访问日志服务

简介 一直以来,日志服务提供了 以restfull API方式写入.查询日志数据,管理自己的项目及日志库.现在日志服务新增提供了mysql 接口,用户可以使用jdbc连接到日志服务,通过标准的sql语法进行查询和计算. 使用方法 数据模型映射 日志服务数据模型 SQL数据模型 project database logstore table accesskeyId user accessKey password 支持的region 目前仅支持经典网络内网访问和VPC网络访问.各个地域的地址参考文档

MySQL慢查询日志总结

慢查询日志概念      MySQL的慢查询日志是MySQL提供的一种日志记录,它用来记录在MySQL中响应时间超过阀值的语句,具体指运行时间超过long_query_time值的SQL,则会被记录到慢查询日志中.long_query_time的默认值为10,意思是运行10S以上的语句.默认情况下,Mysql数据库并不启动慢查询日志,需要我们手动来设置这个参数,当然,如果不是调优需要的话,一般不建议启动该参数,因为开启慢查询日志会或多或少带来一定的性能影响.慢查询日志支持将日志记录写入文件,也支

mysql 开启慢查询 如何打开mysql的慢查询日志记录_Mysql

mysql慢查询日志对于跟踪有问题的查询非常有用,可以分析出当前程序里有很耗费资源的sql语句,那如何打开mysql的慢查询日志记录呢? 其实打开mysql的慢查询日志很简单,只需要在mysql的配置文件里(windows系统是my.ini,linux系统是my.cnf)的[mysqld]下面加上如下代码: 复制代码 代码如下: log-slow-queries=/var/lib/mysql/slowquery.log long_query_time=2 注: log-slow-queries

java实现jdbc查询结果集result转换成对应list集合_java

代码非常的简单,这里就不多废话了,直接奉上 public static <T> List<T> convertToList(ResultSet rs,Class<T> t) throws SQLException { List<Map<String, Object>> list = new ArrayList<Map<String, Object>>(); ResultSetMetaData md = (ResultSet

mysql慢查询日志分析实例

1.MySQL 慢查询日志分析 pt-query-digest分析慢查询日志 pt-query-digest –report slow.log 报告最近半个小时的慢查询: pt-query-digest –report –since 1800s slow.log 报告一个时间段的慢查询: pt-query-digest –report –since '2013-02-10 21:48:59′ –until '2013-02-16 02:33:50′ slow.log 报告只含select语句的慢

MySQL启用慢查询日志记录方法

在MySQL中,慢查询的界定时间是由MySQL内置参数变量long_query_time来指定的,其默认值为10(单位:秒),我们可以通过show variables like 'long_query_time';指令来查看该参数变量的信息: long_query_time的默认值为10秒 不过,在程序开发过程中,我们认为慢速查询的界定时间并没有10秒这么长,依据不同项目的不同需求,我们一般将慢查询的界定时间设定为1~5秒之间.我们可以使用指令set long_query_time = 秒数来设

MySQL中查询日志与慢查询日志的基本学习教程_Mysql

一.查询日志   查询日志记录MySQL中所有的query,通过"--log[=file_name]"来打开该功能.由于记录了所有的query,包括所有的select,体积比较大,开启后对性能也有比较大的影响,所以请大家慎用该功能.一般只用于跟踪某些特殊的sql性能问题才会短暂打开该功能.默认的查询日志文件名为:hostname.log.  ----默认情况下查看是否启用查询日志: [root@node4 mysql5.5]# service mysql start Starting