滿漢樓01-2
4.功能實作01
4.1匯入驅動和工具類
4.1.1匯入驅動
首先將連接mysql的相關jar包引入專案中，分別右鍵，點擊add as library
4.1.2匯入工具類Utility
準備工具類Utility，提高開發效率，并搭建整個專案的整體架構
在實際開發中，公司都會提供相應的工具類和開發庫，可以提高效率
package com.hspedu.mhl.utils;
/**
工具類的作用:
處理各種情況的用戶輸入，并且能夠按照程式員的需求，得到用戶的控制臺輸入，
*/
import java.util.*;
/**
*/
public class Utility {
//靜態屬性，，，
private static Scanner scanner = new Scanner(System.in);
/**
* 功能：讀取鍵盤輸入的一個選單選項，值：1——5的范圍
* @return 1——5
*/
public static char readMenuSelection() {
char c;
for (; ; ) {
String str = readKeyBoard(1, false);//包含一個字符的字串
c = str.charAt(0);//將字串轉換成字符char型別
if (c != '1' && c != '2' &&
c != '3' && c != '4' && c != '5') {
System.out.print("選擇錯誤，請重新輸入：");
} else break;
}
return c;
}
/**
* 功能：讀取鍵盤輸入的一個字符
* @return 一個字符
*/
public static char readChar() {
String str = readKeyBoard(1, false);//就是一個字符
return str.charAt(0);
}
/**
* 功能：讀取鍵盤輸入的一個字符，如果直接按回車，則回傳指定的默認值；否則回傳輸入的那個字符
* @param defaultValue 指定的默認值
* @return 默認值或輸入的字符
*/
public static char readChar(char defaultValue) {
String str = readKeyBoard(1, true);//要么是空字串，要么是一個字符
return (str.length() == 0) ? defaultValue : str.charAt(0);
}
/**
* 功能：讀取鍵盤輸入的整型，長度小于2位
* @return 整數
*/
public static int readInt() {
int n;
for (; ; ) {
String str = readKeyBoard(2, false);//一個整數，長度<=2位
try {
n = Integer.parseInt(str);//將字串轉換成整數
break;
} catch (NumberFormatException e) {
System.out.print("數字輸入錯誤，請重新輸入：");
}
}
return n;
}
/**
* 功能：讀取鍵盤輸入的 整數或默認值，如果直接回車，則回傳默認值，否則回傳輸入的整數
* @param defaultValue 指定的默認值
* @return 整數或默認值
*/
public static int readInt(int defaultValue) {
int n;
for (; ; ) {
String str = readKeyBoard(10, true);
if (str.equals("")) {
return defaultValue;
}
//例外處理...
try {
n = Integer.parseInt(str);
break;
} catch (NumberFormatException e) {
System.out.print("數字輸入錯誤，請重新輸入：");
}
}
return n;
}
/**
* 功能：讀取鍵盤輸入的指定長度的字串
* @param limit 限制的長度
* @return 指定長度的字串
*/
public static String readString(int limit) {
return readKeyBoard(limit, false);
}
/**
* 功能：讀取鍵盤輸入的指定長度的字串或默認值，如果直接回車，回傳默認值，否則回傳字串
* @param limit 限制的長度
* @param defaultValue 指定的默認值
* @return 指定長度的字串
*/
public static String readString(int limit, String defaultValue) {
String str = readKeyBoard(limit, true);
return str.equals("")? defaultValue : str;
}
/**
* 功能：讀取鍵盤輸入的確認選項，Y或N
* 將小的功能，封裝到一個方法中.
* @return Y或N
*/
public static char readConfirmSelection() {
System.out.print("確認是否預訂(Y/N): ");
char c;
for (; ; ) {//無限回圈
//在這里，將接受到字符，轉成了大寫字母
//y => Y n=>N
String str = readKeyBoard(1, false).toUpperCase();
c = str.charAt(0);
if (c == 'Y' || c == 'N') {
break;
} else {
System.out.print("選擇錯誤，請重新輸入：");
}
}
return c;
}
/**
* 功能： 讀取一個字串
* @param limit 讀取的長度
* @param blankReturn 如果為true ,表示 可以讀空字串，
* 如果為false表示 不能讀空字串，
*
* 如果輸入為空，或者輸入大于limit的長度，就會提示重新輸入，
* @return
*/
private static String readKeyBoard(int limit, boolean blankReturn) {
//定義了字串
String line = "";
//scanner.hasNextLine() 判斷有沒有下一行
while (scanner.hasNextLine()) {
line = scanner.nextLine();//讀取這一行
//如果line.length=0, 即用戶沒有輸入任何內容，直接回車
if (line.length() == 0) {
if (blankReturn) return line;//如果blankReturn=true,可以回傳空串
else continue; //如果blankReturn=false,不接受空串，必須輸入內容
}
//如果用戶輸入的內容大于了 limit，就提示重寫輸入
//如果用戶如的內容 >0 <= limit ,我就接受
if (line.length() < 1 || line.length() > limit) {
System.out.print("輸入長度（不能大于" + limit + "）錯誤，請重新輸入：");
continue;
}
break;
}
return line;
}
}
4.1.3匯入工具類JDBCUtilsByDruid
package li.dao_.utils;
import com.alibaba.druid.pool.DruidDataSourceFactory;
import javax.sql.DataSource;
import java.io.FileInputStream;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;
/**
* 基于Druid資料庫連接池的工具類
*/
public class JDBCUtilsByDruid {
private static DataSource ds;
//在靜態代碼塊完成ds的初始化
//靜態代碼塊在加載類的時候只會執行一次，因此資料源也只會初始化一次
static {
Properties properties = new Properties();
try {
properties.load(new FileInputStream("src\\druid.properties"));
ds = DruidDataSourceFactory.createDataSource(properties);
} catch (Exception e) {
e.printStackTrace();
}
}
//撰寫getConnection方法
public static Connection getConnection() throws SQLException {
return ds.getConnection();
}
//關閉連接（注意：在資料庫連接池技術中，close不是真的關閉連接，而是將Connection物件放回連接池中）
public static void close(ResultSet resultSet, Statement statemenat, Connection connection) {
try {
if (resultSet != null) {
resultSet.close();
}
if (statemenat != null) {
statemenat.close();
}
if (connection != null) {
connection.close();
}
} catch (SQLException e) {
throw new RuntimeException(e);
}
}
}
- 德魯伊的組態檔，放在src目錄下
#key=value
driverClassName=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/mhl?rewriteBatchedStatements=true
#url=jdbc:mysql://localhost:3306/mhl
username=root
password=123456
#initial connection Size
initialSize=10
#min idle connecton size
minIdle=5
#max active connection size
maxActive=50
#max wait time (5000 mil seconds)
maxWait=5000
4.1.4匯入BasicDAO
package com.li.mhl.dao;
import com.li.mhl.utils.JDBCUtilsByDruid;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.BeanHandler;
import org.apache.commons.dbutils.handlers.BeanListHandler;
import org.apache.commons.dbutils.handlers.ScalarHandler;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;
/**
* 開發BasicDAO，是其他DAO的父類
*/
public class BasicDAO<T> {//泛型指定具體的型別
private QueryRunner qr = new QueryRunner();
//開發通用的dml方法，針對任意的表
/**
* @param sql 傳入的SQL陳述句,可以有占位符?
* @param parameters 傳入占位符?的具體的值，可以是多個
* @return 回傳的值是受影響的行數
*/
public int update(String sql, Object... parameters) { //可變引數 Object… parameters
Connection connection = null;
try {
connection = JDBCUtilsByDruid.getConnection();
int update = qr.update(connection, sql, parameters);
return update;
} catch (SQLException e) {
throw new RuntimeException(e);//將一個編譯例外轉變為運行例外
} finally {
JDBCUtilsByDruid.close(null, null, connection);
}
}
//回傳多個物件（即查詢的結果是多行），針對任意的表（多行多列）
/**
* @param sql 傳入的SQL陳述句,可以有占位符?
* @param clazz 傳入一個類的Class物件，比如 Actor.class[底層需要通過反射來創建Javabean物件]
* @param parameters 傳入占位符?的具體的值，可以是多個
* @return 根據傳入的class物件 Xxx.class 回傳對應的ArrayList集合
*/
public List<T> queryMulti(String sql, Class<T> clazz, Object... parameters) {
Connection connection = null;
try {
connection = JDBCUtilsByDruid.getConnection();
return qr.query(connection, sql, new BeanListHandler<T>(clazz), parameters);
} catch (SQLException e) {
throw new RuntimeException(e);//將一個編譯例外轉變為運行例外
} finally {
JDBCUtilsByDruid.close(null, null, connection);
}
}
//查詢單行結果 的通用方法（單行多列）
public T querySingle(String sql, Class<T> clazz, Object... parameters) {
Connection connection = null;
try {
connection = JDBCUtilsByDruid.getConnection();
return qr.query(connection, sql, new BeanHandler<T>(clazz), parameters);
} catch (SQLException e) {
throw new RuntimeException(e);//將一個編譯例外轉變為運行例外
} finally {
JDBCUtilsByDruid.close(null, null, connection);
}
}
//查詢單行單列的方法，即回傳單值的方法
public Object queryScalar(String sql, Object... parameters) {
Connection connection = null;
try {
connection = JDBCUtilsByDruid.getConnection();
return qr.query(connection, sql, new ScalarHandler(), parameters);
} catch (SQLException e) {
throw new RuntimeException(e);//將一個編譯例外轉變為運行例外
} finally {
JDBCUtilsByDruid.close(null, null, connection);
}
}
}
進過測驗，工具類使用正常
轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/518503.html
標籤：其他
上一篇：VSCode搭建C和C++環境
下一篇：python基礎-字典常用操作