Chinaunix首页 | 论坛 | 博客

逊云锋的ChinaUnix博客

首页　| 　博文目录　| 　关于我

逊云锋

  • 博客访问： 874946
  • 博文数量： 372
  • 博客积分： 10063
  • 博客等级： 中将
  • 技术积分： 4220
  • 用 户 组： 普通用户
  • 注册时间： 2012-02-24 11:36
文章分类

全部博文（372）

文章存档

2012年（372）

我的朋友
最近访客
推荐博文
相关博文
log4j+JDBC+mySQL 将对象写入数据库

分类： 虚拟化

2012-03-20 20:49:23

一、写前唠叨

最近写了一个关于将对象通过log4j的形式保存到数据库的例子，因对这个log4j正在入门，所以做之前查过很多资料，不过网上的信息比较简单，如下：

1.所有信息几乎全部在配置文件中进行获取，如：数据库相关的连接、用户名、密码、sql语句；日志相关的appender、输出、格式化、参数；

2.写到数据库中的仅是一个字符串而不是一个对象，如：将一个对象本身以及它的各个数据作为一条记录存到数据库

3.代码的灵活性较低，如：只能存比较简单的数据类型，如保存一个对象及属性的话，就不太容易做了。

当然，网上的这些资料当然是为了最基础的入门而做的，因此简单了些，但也不乏比较深奥的资料，比如穿件连接池，考虑缓存等等。。

二、我的做法

1.通过继承JDBCAppender实现日志的写入的

2.通过JDBC连接数据库（也可通过HIBERNATE）

3.数据库和log4j的基本信息配置到properties中，但数据库可以自由选择多种数据库（在配置文件中配置即可）

4.将对象的属性存到库中

三、项目例子

1.项目结构图：见附件，项目结构图.png

2. 数据库：MYSQL 库名：LOG4J 表名：LogMessage/StudentMessage

表结构请看附件：LogMessage.png/StudentMessage.png

3.代码及说明

log4j.properties :分别输出指定为：控制台、文件（log.log）、数据库

Java代码 复制代码 收藏代码
  1. log4j.rootLogger=INFO,appender1,appender2,DATABASE
  3. # console
  4. log4j.appender.appender1=org.apache.log4j.ConsoleAppender
  5. log4j.appender.appender1.layout=org.apache.log4j.PatternLayout
  6. log4j.appender.appender1.layout.ConversionPattern=%d{yyyy-MM-dd HH:mm:ss:SSS}[%p]: %m%n
  8. # file
  9. log4j.appender.appender2=org.apache.log4j.FileAppender
  10. log4j.appender.appender2.File=log.log
  11. log4j.appender.appender2.layout=org.apache.log4j.PatternLayout
  12. log4j.appender.appender2.layout.ConversionPattern=%d{yyyy-MM-dd HH:mm:ss:SSS}[%p]: %m%n
  14. #mysql dbappender test
  15. log4j.appender.DATABASE.driver=com.mysql.jdbc.Driver
  16. log4j.appender.DATABASE.URL=jdbc:mysql://127.0.0.1:3306/LOG4J
  17. log4j.appender.DATABASE.username=root
  18. log4j.appender.DATABASE.password=root
  19. log4j.appender.DATABASE=control.DbAppender
  20. log4j.appender.DATABASE.layout=org.apache.log4j.PatternLayout
  21. log4j.appender.DATABASE.layout.ConversionPattern=[framework] %d - %c -%-4r [%t] %-5p %c %x - %m%n %L
log4j.rootLogger=INFO,appender1,appender2,DATABASE # console log4j.appender.appender1=org.apache.log4j.ConsoleAppender log4j.appender.appender1.layout=org.apache.log4j.PatternLayout log4j.appender.appender1.layout.ConversionPattern=%d{yyyy-MM-dd HH:mm:ss:SSS}[%p]: %m%n # file log4j.appender.appender2=org.apache.log4j.FileAppender log4j.appender.appender2.File=log.log log4j.appender.appender2.layout=org.apache.log4j.PatternLayout log4j.appender.appender2.layout.ConversionPattern=%d{yyyy-MM-dd HH:mm:ss:SSS}[%p]: %m%n #mysql dbappender test log4j.appender.DATABASE.driver=com.mysql.jdbc.Driver log4j.appender.DATABASE.URL=jdbc:mysql://127.0.0.1:3306/LOG4J log4j.appender.DATABASE.username=root log4j.appender.DATABASE.password=root log4j.appender.DATABASE=control.DbAppender log4j.appender.DATABASE.layout=org.apache.log4j.PatternLayout log4j.appender.DATABASE.layout.ConversionPattern=[framework] %d - %c -%-4r [%t] %-5p %c %x - %m%n %L

Conorl包——DbAppender.java :日志提交中转站，提取日志信息，处理后进行数据库操作插入对应的表中

Java代码 复制代码 收藏代码
  1. package control;
  3. import java.sql.Connection;
  4. import java.sql.ResultSet;
  5. import java.sql.SQLException;
  6. import java.sql.Statement;
  7. import java.util.Hashtable;
  8. import java.util.Iterator;
  9. import java.util.Map;
  11. import org.apache.log4j.jdbc.JDBCAppender;
  12. import org.apache.log4j.spi.ErrorCode;
  13. import org.apache.log4j.spi.LoggingEvent;
  15. import bean.HashMapping;
  16. import bean.Students;
  17. import bean.UserBean;
  19. import dao.JdbcUtils;
  20. import dao.StudentsUtil;
  21. import dao.UserUtil;
  23. public class DbAppender extends JDBCAppender {
  25. protected void closeConnection(Connection con) {
  26. // TODO Auto-generated method stub
  27. // super.closeConnection(con);
  28. JdbcUtils.close(con);
  30. }
  32. @Override
  33. protected void execute(String sql) throws SQLException {
  34. // TODO Auto-generated method stub
  35. // super.execute(arg0);
  36. int flag = 0;
  37. int end = sql.lastIndexOf(")");
  38. String sqls = sql.substring(0, end + 1);
  39. String beanname = sql.substring(end + 1);
  40. if (beanname.equals("UserBean")) {
  41. flag = UserUtil.insertUser(sqls);
  42. } else if (beanname.equals("Students")) {
  43. flag = StudentsUtil.insertStudent(sqls);
  44. }
  45. System.out.println(flag == 0 ? "insert fail!" : "insert successful!");
  46. }
  48. @Override
  49. protected Connection getConnection() throws SQLException {
  50. // TODO Auto-generated method stub
  51. // return super.getConnection();
  52. if (connection == null) {
  53. connection = JdbcUtils.getConnection();
  54. }
  55. return connection;
  56. }
  58. @Override
  59. protected String getLogStatement(LoggingEvent event) {
  60. // TODO Auto-generated method stub
  61. // return super.getLogStatement(event);
  62. StringBuffer sbuf = new StringBuffer();
  63. Hashtable hm = (Hashtable) event.getMessage();
  64. String sql = null;
  65. if ((hm.get("beanname")).equals("UserBean")) {
  66. sbuf.append(UserUtil.insertSql());
  67. sql = sbuf.toString();
  68. int end = sql.lastIndexOf("(");
  69. sql = sql.substring(0, end) + "('" + hm.get(HashMapping.USER_TIME)
  70. + "','" + event.getMessage() + "','"
  71. + hm.get(HashMapping.USER_USERNAME) + "','"
  72. + hm.get(HashMapping.USER_PASSWORD) + "')";
  73. System.out.println(sql);
  74. return sql + hm.get("beanname");
  75. } else if ((hm.get("beanname")).equals("Students")) {
  76. sbuf.append(StudentsUtil.insertSql());
  77. sql = sbuf.toString();
  78. int end = sql.lastIndexOf("(");
  79. sql = sql.substring(0, end)
  80. + "('"
  81. + hm.get(HashMapping.STUDENT_NAME)
  82. + "','"
  83. + hm.get(HashMapping.STUDENT_AGE)
  84. + "','"
  85. + (((Integer) (hm.get(HashMapping.STUDENT_***))) == 1 ? "F"
  86. : "M") + "','" + hm.get(HashMapping.STUDENT_TIME)
  87. + "')";
  88. System.out.println(sql);
  89. return sql + hm.get("beanname");
  90. }
  91. return sql;
  93. }
  95. }
package control; import java.sql.Connection; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import java.util.Hashtable; import java.util.Iterator; import java.util.Map; import org.apache.log4j.jdbc.JDBCAppender; import org.apache.log4j.spi.ErrorCode; import org.apache.log4j.spi.LoggingEvent; import bean.HashMapping; import bean.Students; import bean.UserBean; import dao.JdbcUtils; import dao.StudentsUtil; import dao.UserUtil; public class DbAppender extends JDBCAppender { protected void closeConnection(Connection con) { // TODO Auto-generated method stub // super.closeConnection(con); JdbcUtils.close(con); } @Override protected void execute(String sql) throws SQLException { // TODO Auto-generated method stub // super.execute(arg0); int flag = 0; int end = sql.lastIndexOf(")"); String sqls = sql.substring(0, end + 1); String beanname = sql.substring(end + 1); if (beanname.equals("UserBean")) { flag = UserUtil.insertUser(sqls); } else if (beanname.equals("Students")) { flag = StudentsUtil.insertStudent(sqls); } System.out.println(flag == 0 ? "insert fail!" : "insert successful!"); } @Override protected Connection getConnection() throws SQLException { // TODO Auto-generated method stub // return super.getConnection(); if (connection == null) { connection = JdbcUtils.getConnection(); } return connection; } @Override protected String getLogStatement(LoggingEvent event) { // TODO Auto-generated method stub // return super.getLogStatement(event); StringBuffer sbuf = new StringBuffer(); Hashtable hm = (Hashtable) event.getMessage(); String sql = null; if ((hm.get("beanname")).equals("UserBean")) { sbuf.append(UserUtil.insertSql()); sql = sbuf.toString(); int end = sql.lastIndexOf("("); sql = sql.substring(0, end) + "('" + hm.get(HashMapping.USER_TIME) + "','" + event.getMessage() + "','" + hm.get(HashMapping.USER_USERNAME) + "','" + hm.get(HashMapping.USER_PASSWORD) + "')"; System.out.println(sql); return sql + hm.get("beanname"); } else if ((hm.get("beanname")).equals("Students")) { sbuf.append(StudentsUtil.insertSql()); sql = sbuf.toString(); int end = sql.lastIndexOf("("); sql = sql.substring(0, end) + "('" + hm.get(HashMapping.STUDENT_NAME) + "','" + hm.get(HashMapping.STUDENT_AGE) + "','" + (((Integer) (hm.get(HashMapping.STUDENT_***))) == 1 ? "F" : "M") + "','" + hm.get(HashMapping.STUDENT_TIME) + "')"; System.out.println(sql); return sql + hm.get("beanname"); } return sql; } }

Bean包中的类——HashMapping.java ：将属性设置成常量（即键-值对中的键），便于代码中进行键值对的读取。

Java代码 复制代码 收藏代码
  1. package bean;
  3. public class HashMapping {
  5. public static final String USER_USERNAME = "username";
  6. public static final String USER_PASSWORD = "password";
  7. public static final String USER_TIME = "time";
  9. public static final String STUDENT_NAME = "name";
  10. public static final String STUDENT_AGE = "age";
  11. public static final String STUDENT_*** = "***";
  12. public static final String STUDENT_TIME = "time";
  13. }
package bean; public class HashMapping { public static final String USER_USERNAME = "username"; public static final String USER_PASSWORD = "password"; public static final String USER_TIME = "time"; public static final String STUDENT_NAME = "name"; public static final String STUDENT_AGE = "age"; public static final String STUDENT_*** = "***"; public static final String STUDENT_TIME = "time"; }

Bean包中的类——UserBean.java/Students.java: 对LogMessage/studentMessage表及此对象持久化

Java代码 复制代码 收藏代码
  1. package bean;
  3. public class Students {
  5. private String name;
  6. private int age;
  7. private int ***;
  8. private String time;
  10. public String getTime() {
  11. return time;
  12. }
  14. public void setTime(String time) {
  15. this.time = time;
  16. }
  18. public String getName() {
  19. return name;
  20. }
  22. public void setName(String name) {
  23. this.name = name;
  24. }
  26. public int getAge() {
  27. return age;
  28. }
  30. public void setAge(int age) {
  31. this.age = age;
  32. }
  34. public int get***() {
  35. return ***;
  36. }
  38. public void set***(int ***) {
  39. this.*** = ***;
  40. }
  42. }
  43. //===============================================
  44. package bean;
  46. import java.sql.Date;
  48. public class UserBean {
  50. private String username;
  51. private String password;
  52. private String Time;
  53. private String Note;
  55. public String getTime() {
  56. return Time;
  57. }
  59. public void setTime(String time) {
  60. Time = time;
  61. }
  63. public String getNote() {
  64. return Note;
  65. }
  67. public void setNote(String note) {
  68. Note = note;
  69. }
  71. public String getUsername() {
  72. return username;
  73. }
  75. public void setUsername(String username) {
  76. this.username = username;
  77. }
  79. public String getPassword() {
  80. return password;
  81. }
  83. public void setPassword(String password) {
  84. this.password = password;
  85. }
  87. }
package bean; public class Students { private String name; private int age; private int ***; private String time; public String getTime() { return time; } public void setTime(String time) { this.time = time; } public String getName() { return name; } public void setName(String name) { this.name = name; } public int getAge() { return age; } public void setAge(int age) { this.age = age; } public int get***() { return ***; } public void set***(int ***) { this.*** = ***; } } //=============================================== package bean; import java.sql.Date; public class UserBean { private String username; private String password; private String Time; private String Note; public String getTime() { return Time; } public void setTime(String time) { Time = time; } public String getNote() { return Note; } public void setNote(String note) { Note = note; } public String getUsername() { return username; } public void setUsername(String username) { this.username = username; } public String getPassword() { return password; } public void setPassword(String password) { this.password = password; } }

Dao中的包——GetObject.java: 将对象放到hashtable中并发送到dbappender中

Java代码 复制代码 收藏代码
  1. package dao;
  3. import java.lang.reflect.InvocationTargetException;
  4. import java.lang.reflect.Method;
  5. import java.text.SimpleDateFormat;
  6. import java.util.Date;
  7. import java.util.Hashtable;
  9. import org.apache.log4j.Logger;
  10. import org.apache.log4j.PropertyConfigurator;
  12. import test.Test;
  14. import bean.Students;
  15. import bean.UserBean;
  17. public class GetObject {
  18. private Logger logger = Logger.getLogger(GetObject.class);
  19. private UserBean ub;
  20. private Students st;
  21. private SimpleDateFormat sf;
  23. // 保存对象
  24. public UserBean insertInfo(String username, String password) {
  26. ub = new UserBean();
  27. ub.setUsername(username);
  28. ub.setPassword(password);
  29. return ub;
  31. }
  33. public Logger getLogger() {
  34. return logger;
  35. }
  37. public void setLogger(Logger logger) {
  38. this.logger = logger;
  39. }
  41. public UserBean getUb() {
  42. return ub;
  43. }
  45. public void setUb(UserBean ub) {
  46. this.ub = ub;
  47. }
  49. public Students getSt() {
  50. return st;
  51. }
  53. public void setSt(Students st) {
  54. this.st = st;
  55. }
  57. public SimpleDateFormat getSf() {
  58. return sf;
  59. }
  61. public void setSf(SimpleDateFormat sf) {
  62. this.sf = sf;
  63. }
  65. public Students insertInfo(String name, int age, int ***) {
  66. st = new Students();
  67. st.setName(name);
  68. st.setAge(age);
  69. st.set***(***);
  70. return st;
  71. }
  73. // bean key-value
  74. public void getMethod(Object obj) {
  76. sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss:SSS");
  77. PropertyConfigurator.configure("log4j.properties");
  78. Hashtable ht = new Hashtable();
  79. ht.clear();
  80. if (obj instanceof UserBean) {
  81. ht.put("username", ub.getUsername());
  82. ht.put("password", ub.getPassword());
  83. ht.put("time", sf.format(new Date()));
  84. ht.put("beanname", "UserBean");
  85. } else if (obj instanceof Students) {
  86. ht.put("name", st.getName());
  87. ht.put("age", st.getAge());
  88. ht.put("***", st.get***());
  89. ht.put("time", sf.format(new Date()));
  90. ht.put("beanname","Students");
  91. }
  92. logger.info(ht);
  94. }
  96. }
package dao; import java.lang.reflect.InvocationTargetException; import java.lang.reflect.Method; import java.text.SimpleDateFormat; import java.util.Date; import java.util.Hashtable; import org.apache.log4j.Logger; import org.apache.log4j.PropertyConfigurator; import test.Test; import bean.Students; import bean.UserBean; public class GetObject { private Logger logger = Logger.getLogger(GetObject.class); private UserBean ub; private Students st; private SimpleDateFormat sf; // 保存对象 public UserBean insertInfo(String username, String password) { ub = new UserBean(); ub.setUsername(username); ub.setPassword(password); return ub; } public Logger getLogger() { return logger; } public void setLogger(Logger logger) { this.logger = logger; } public UserBean getUb() { return ub; } public void setUb(UserBean ub) { this.ub = ub; } public Students getSt() { return st; } public void setSt(Students st) { this.st = st; } public SimpleDateFormat getSf() { return sf; } public void setSf(SimpleDateFormat sf) { this.sf = sf; } public Students insertInfo(String name, int age, int ***) { st = new Students(); st.setName(name); st.setAge(age); st.set***(***); return st; } // bean key-value public void getMethod(Object obj) { sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss:SSS"); PropertyConfigurator.configure("log4j.properties"); Hashtable ht = new Hashtable(); ht.clear(); if (obj instanceof UserBean) { ht.put("username", ub.getUsername()); ht.put("password", ub.getPassword()); ht.put("time", sf.format(new Date())); ht.put("beanname", "UserBean"); } else if (obj instanceof Students) { ht.put("name", st.getName()); ht.put("age", st.getAge()); ht.put("***", st.get***()); ht.put("time", sf.format(new Date())); ht.put("beanname","Students"); } logger.info(ht); } }

Dao中的包——JdbcUtils.java: 数据库的动态链接

Java代码 复制代码 收藏代码
  1. package dao;
  3. import java.io.FileInputStream;
  4. import java.io.IOException;
  5. import java.sql.Connection;
  6. import java.sql.DriverManager;
  7. import java.sql.ResultSet;
  8. import java.sql.SQLException;
  9. import java.sql.Statement;
  10. import java.util.Iterator;
  11. import java.util.Properties;
  12. import java.util.Set;
  14. public final class JdbcUtils {
  15. //
  16. private static String url = null;
  17. private static String driver = null;
  18. private static String username = null;
  19. private static String password = null;
  21. private JdbcUtils() {
  23. }
  24. static{
  25. try {
  26. getProperties();
  27. Class.forName(driver);
  28. } catch (ClassNotFoundException e) {
  29. // TODO Auto-generated catch block
  30. e.printStackTrace();
  31. }
  32. }
  34. public static Connection getConnection() throws SQLException {
  36. return DriverManager.getConnection(url, username, password);
  37. }
  39. public static void close(Connection conn) {
  41. try {
  42. if (conn != null)
  43. conn.close();
  44. } catch (SQLException e) {
  45. // TODO Auto-generated catch block
  46. e.printStackTrace();
  47. }
  48. }
  50. public static void getProperties() {
  52. Properties props = new Properties();
  53. FileInputStream istream = null;
  54. try {
  55. istream = new FileInputStream("log4j.properties");
  56. props.load(istream);
  57. Set s = props.keySet();
  58. Iterator it = s.iterator();
  59. while (it.hasNext()) {
  60. String id = (String) it.next();
  61. String value = props.getProperty(id);
  62. if(id.equals("log4j.appender.DATABASE.driver")){
  63. driver = value;
  64. }else if(id.equals("log4j.appender.DATABASE.URL")){
  65. url = value;
  66. }else if(id.equals("log4j.appender.DATABASE.username")){
  67. username = value;
  68. }else if(id.equals("log4j.appender.DATABASE.password")){
  69. password = value;
  70. }
  71. // System.out.println(id + ":=" + value);
  72. }
  73. } catch (Exception e) {
  74. // TODO Auto-generated catch block
  75. e.printStackTrace();
  76. } finally {
  77. try {
  78. istream.close();
  79. } catch (IOException e) {
  80. // TODO Auto-generated catch block
  81. e.printStackTrace();
  82. }
  83. }
  85. }
  87. }
package dao; import java.io.FileInputStream; import java.io.IOException; import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import java.util.Iterator; import java.util.Properties; import java.util.Set; public final class JdbcUtils { // private static String url = null; private static String driver = null; private static String username = null; private static String password = null; private JdbcUtils() { } static{ try { getProperties(); Class.forName(driver); } catch (ClassNotFoundException e) { // TODO Auto-generated catch block e.printStackTrace(); } } public static Connection getConnection() throws SQLException { return DriverManager.getConnection(url, username, password); } public static void close(Connection conn) { try { if (conn != null) conn.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } public static void getProperties() { Properties props = new Properties(); FileInputStream istream = null; try { istream = new FileInputStream("log4j.properties"); props.load(istream); Set s = props.keySet(); Iterator it = s.iterator(); while (it.hasNext()) { String id = (String) it.next(); String value = props.getProperty(id); if(id.equals("log4j.appender.DATABASE.driver")){ driver = value; }else if(id.equals("log4j.appender.DATABASE.URL")){ url = value; }else if(id.equals("log4j.appender.DATABASE.username")){ username = value; }else if(id.equals("log4j.appender.DATABASE.password")){ password = value; } // System.out.println(id + ":=" + value); } } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } finally { try { istream.close(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } } }

Dao中的包——StudentsUtil.java/UserUtil.java: 对各自的表进行数据库的操作

Java代码 复制代码 收藏代码
  1. package dao;
  3. import java.sql.Connection;
  4. import java.sql.SQLException;
  5. import java.sql.Statement;
  7. public class StudentsUtil {
  9. public static int insertStudent(String sql) {
  11. Connection conn = null;
  12. Statement sm = null;
  14. int flag = 0;
  16. try {
  17. conn = JdbcUtils.getConnection();
  18. sm = conn.createStatement();
  19. sm.execute(sql);
  20. flag = 1;
  21. } catch (SQLException e) {
  22. // TODO Auto-generated catch block
  23. System.out.println("insert fail!");
  24. } finally {
  25. if (sm != null) {
  26. try {
  27. sm.close();
  28. } catch (SQLException e) {
  29. // TODO Auto-generated catch block
  30. e.printStackTrace();
  31. }
  32. }
  33. JdbcUtils.close(conn);
  35. }
  37. return flag;
  39. }
  41. public static String insertSql() {
  42. return "INSERT INTO StudentMessage(Name,Age,***,Time) values(";
  43. }
  44. }
  45. //===============================================
  46. package dao;
  48. import java.sql.CallableStatement;
  49. import java.sql.Connection;
  50. import java.sql.ResultSet;
  51. import java.sql.SQLException;
  52. import java.sql.Statement;
  54. import bean.UserBean;
  56. public class UserUtil {
  58. public static int insertUser(String sql) {
  60. Connection conn = null;
  61. Statement sm = null;
  63. int flag = 0;
  65. try {
  66. conn = JdbcUtils.getConnection();
  67. sm = conn.createStatement();
  68. sm.execute(sql);
  69. flag = 1;
  70. } catch (SQLException e) {
  71. // TODO Auto-generated catch block
  72. System.out.println("insert fail!");
  73. } finally {
  74. if (sm != null) {
  75. try {
  76. sm.close();
  77. } catch (SQLException e) {
  78. // TODO Auto-generated catch block
  79. e.printStackTrace();
  80. }
  81. }
  82. JdbcUtils.close(conn);
  84. }
  86. return flag;
  88. }
  89. public static String insertSql(){
  90. return "INSERT INTO LogMessage(Time,Note,Username,Password) values(";
  91. }
  93. }
package dao; import java.sql.Connection; import java.sql.SQLException; import java.sql.Statement; public class StudentsUtil { public static int insertStudent(String sql) { Connection conn = null; Statement sm = null; int flag = 0; try { conn = JdbcUtils.getConnection(); sm = conn.createStatement(); sm.execute(sql); flag = 1; } catch (SQLException e) { // TODO Auto-generated catch block System.out.println("insert fail!"); } finally { if (sm != null) { try { sm.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } JdbcUtils.close(conn); } return flag; } public static String insertSql() { return "INSERT INTO StudentMessage(Name,Age,***,Time) values("; } } //=============================================== package dao; import java.sql.CallableStatement; import java.sql.Connection; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import bean.UserBean; public class UserUtil { public static int insertUser(String sql) { Connection conn = null; Statement sm = null; int flag = 0; try { conn = JdbcUtils.getConnection(); sm = conn.createStatement(); sm.execute(sql); flag = 1; } catch (SQLException e) { // TODO Auto-generated catch block System.out.println("insert fail!"); } finally { if (sm != null) { try { sm.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } JdbcUtils.close(conn); } return flag; } public static String insertSql(){ return "INSERT INTO LogMessage(Time,Note,Username,Password) values("; } }

test包——test.java :测试类

Java代码 复制代码 收藏代码
  1. package test;
  3. import java.lang.reflect.InvocationTargetException;
  5. import org.apache.log4j.Logger;
  6. import org.apache.log4j.MDC;
  7. import org.apache.log4j.PropertyConfigurator;
  8. import org.apache.log4j.jdbc.JDBCAppender;
  9. import org.omg.CORBA.Request;
  11. import dao.GetObject;
  13. import bean.Students;
  14. import bean.UserBean;
  16. public class Test {
  18. public static void main(String[] args) {
  20. Test dbt = new Test();
  21. dbt.testUser();
  23. }
  25. public void testUser() {
  26. try {
  27. GetObject go = new GetObject();
  28. UserBean ub = go.insertInfo("TIBCO-VANCEINFO", "TIBCO-12345");
  29. go.getMethod(ub);
  30. // Students st = go.insertInfo("TIBCO", 21, 2);
  31. // go.getMethod(st);
  32. } catch (SecurityException e) {
  33. // TODO Auto-generated catch block
  34. e.printStackTrace();
  35. }
  37. }
  39. }
package test; import java.lang.reflect.InvocationTargetException; import org.apache.log4j.Logger; import org.apache.log4j.MDC; import org.apache.log4j.PropertyConfigurator; import org.apache.log4j.jdbc.JDBCAppender; import org.omg.CORBA.Request; import dao.GetObject; import bean.Students; import bean.UserBean; public class Test { public static void main(String[] args) { Test dbt = new Test(); dbt.testUser(); } public void testUser() { try { GetObject go = new GetObject(); UserBean ub = go.insertInfo("TIBCO-VANCEINFO", "TIBCO-12345"); go.getMethod(ub); // Students st = go.insertInfo("TIBCO", 21, 2); // go.getMethod(st); } catch (SecurityException e) { // TODO Auto-generated catch block e.printStackTrace(); } } }

结果见附加：stuM.png/logM.png

阅读(1497) | 评论(0) | 转发(0) |
0

上一篇：半虚拟化的xen下不可能成功配置lvs的DR模式

下一篇：YLMF OS安装vmare tool

给主人留下些什么吧！~~
关于我们 | 关于IT168 | 联系方式 | 广告合作 | 法律声明 | 免费注册

Copyright 2001-2010 ChinaUnix.net All Rights Reserved 北京皓辰网域网络信息技术有限公司. 版权所有

感谢所有关心和支持过ChinaUnix的朋友们

16024965号-6