1. 程式人生 > >jdbc寫一個訪問資料庫的工具類

jdbc寫一個訪問資料庫的工具類

操作的工具類

package com.zjw.jdbc2;
/**
 * jdbc操作的工具類
 * @author Administrator
 *
 */

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class JdbcUtils
{
	private JdbcUtils() {}
	
	private static String url = "jdbc:mysql://localhost:3306/aaa?useSSL=false&serverTimezone=UTC";
	private static String user = "root" ;
	private static String password = "123456";
	
	public static Connection getConnection() 
	{
		Connection con = null;
		try
		{
			//載入驅動
			Class.forName("com.mysql.cj.jdbc.Driver");
			//獲取連線
			con = DriverManager.getConnection(url, user, password);
		} catch (ClassNotFoundException | SQLException e)
		{
			e.printStackTrace();
		}
		//返回連線結果
		return con;
	}
	/**
	 *  關閉連線 包含三個引數
	 * @param con 連線物件
	 * @param sta Statement物件
	 * @param res 結果集物件
	 */
	public static void closeConnection(Connection con,Statement sta,ResultSet res) 
	{
		try
		{
			if(res != null)
			res.close();
		} catch (SQLException e)
		{
			e.printStackTrace();
		}
		try
		{
			if(sta != null)
			sta.close();
		} catch (SQLException e)
		{
			e.printStackTrace();
		}
		try
		{
			if(con != null)
			con.close();
		} catch (SQLException e)
		{
			e.printStackTrace();
		}
	}
	/**
	 * 關閉連線 包含兩個引數
	 * @param con 連線物件
	 * @param sta Statement物件
	 */
	public static void closeConnection(Connection con,Statement sta) 
	{
		try
		{
			if(sta != null)
			sta.close();
		} catch (SQLException e)
		{
			e.printStackTrace();
		}
		try
		{
			if(con != null)
			con.close();
		} catch (SQLException e)
		{
			e.printStackTrace();
		}
	}
}

 利用工具類來操作資料庫

package com.zjw.jdbc2;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
/**
 * 使用jdbc編寫的工具類操作資料庫
 * @author Administrator
 *
 */
public class JdbcUtilTest
{
	public static void main(String[] args)
	{
		//獲取連線
		Connection con = JdbcUtils.getConnection();
		//操作資料庫
		String sql = "SELECT * FROM category;";
		try
		{
			PreparedStatement pst = con.prepareStatement(sql);
			ResultSet res = pst.executeQuery();
			while(res.next())
			{
				String sid = res.getString("sid");
				String sname = res.getString("sname");
				System.out.println(sid+ " "+ sname);
			}
			//關閉連線
			JdbcUtils.closeConnection(con, pst, res);
		} catch (SQLException e)
		{
			e.printStackTrace();
		}
	}
}

結果