mysqldriver.java

这个是读取日志文件,并且处理,然后把它插入到数据库中

package com.jb;

import java.io.IOException;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

public class MysqlDriver {
	//static String url = "jdbc:mysql://localhost/db1?user=root&password=&characterEncoding=GBK";

	public static Connection getConnection(){
	XMLProperties pro = null;
		try {
			pro = new XMLProperties("db-config.xml");
		} catch (IOException e1) {
			// TODO Auto-generated catch block
			e1.printStackTrace();
		}
		String url = pro.getProperty("c1db.defaultProvider.serverURL"); 
		String username = pro.getProperty("c1db.defaultProvider.username");
		String password = pro.getProperty("c1db.defaultProvider.password");
		
		
		try {
			Class.forName("com.mysql.jdbc.Driver").newInstance();
		} catch (InstantiationException e) {
			e.printStackTrace();
		} catch (IllegalAccessException e) {
			e.printStackTrace();
		} catch (ClassNotFoundException e) {
			e.printStackTrace();
		}
		try {
			// for (int i = 0; i < _pool; i++) {
			return DriverManager.getConnection(url,username,password);
			// }
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return null;
	}
	

	public static void closeConnection(PreparedStatement pstmt, Connection conn) {
		try {
			if (null != pstmt) {
				pstmt.close();
			}
			if (null != conn) {
				closeConnection(conn);
			}
		} catch (SQLException sqle) {
			sqle.printStackTrace();
		} finally {
			if (null != pstmt) {
				try {
					pstmt.close();
				} catch (SQLException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
			}
			if (null != conn) {
				closeConnection(conn);
			}
		}

	}

	public static void closeConnection(ResultSet rs, PreparedStatement pstmt,
			Connection conn) {
		try {
			if (null != rs) {
				rs.close();
			}
			if (null != pstmt) {
				pstmt.close();
			}
			if (null != conn) {
				closeConnection(conn);
			}
		} catch (SQLException sqle) {
			sqle.printStackTrace();
		} finally {
			if (null != rs) {
				try {
					rs.close();
				} catch (SQLException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
			}
			if (null != pstmt) {
				try {
					pstmt.close();
				} catch (SQLException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
			}
			if (null != conn) {
				closeConnection(conn);
			}
		}

	}

	private static void closeConnection(Connection conn) {
		try {
			conn.close();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} finally {
			try {
				conn.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
	}
}