package org.springblade.consumption.utils;
import org.springblade.consumption.constant.ConsumptionConstant;
import org.springblade.core.tool.utils.Func;

import java.sql.*;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
public class ConsumptionUtil {
	/**
	 * 消費機模組 連線資料庫獲取資訊
	 * @return
	 */
	public static List<Map<String,Object>> getSqlResult(String sql,Map<String,String>map){
		List<Map<String,Object>> list = new ArrayList();
		try {
			//一開始必須填一個已經存在的資料庫
			String url = ConsumptionConstant.url;
			Connection conn = DriverManager.getConnection(url, ConsumptionConstant.userName, ConsumptionConstant.password);// 連線資料庫
			//Statement stat = conn.createStatement();//建立一個 Statement 物件來將 SQL 語句傳送到資料庫。
			PreparedStatement stat = conn.prepareStatement(sql);
			if(Func.isNotEmpty(map)){
				//餐別
				if(map.containsKey("mealType")){
					stat.setString(1, map.get("mealType"));
				}
				//消費時間
				if(map.containsKey("date")){
					stat.setDate(2,Date.valueOf(map.get("date")));
				}
			}

			ResultSet resultSet=stat.executeQuery();

			ResultSetMetaData md = resultSet.getMetaData();
			int columnCount = md.getColumnCount();
			while (resultSet.next()) {
				Map<String,Object> rowData = new HashMap();
				for (int i = 1; i <= columnCount; i++) {
					rowData.put(md.getColumnName(i), resultSet.getObject(i));
				}
				list.add(rowData);
			}
			System.out.println("list====="+list);
			resultSet.close();
		} catch (Exception e) {
			e.printStackTrace();
		}
     return list;
	}
}




package org.springblade.consumption.utils;
import org.springblade.consumption.constant.ConsumptionConstant;
import org.springblade.core.tool.utils.Func;

import java.sql.*;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
public class ConsumptionUtil {
	/**
	 * 消費機模組 連線資料庫獲取資訊
	 * @return
	 */
	public static List<Map<String,Object>> getSqlResult(String sql,Map<String,String>map){
		List<Map<String,Object>> list = new ArrayList();
		try {
			//一開始必須填一個已經存在的資料庫
			String url = ConsumptionConstant.url;
			Connection conn = DriverManager.getConnection(url, ConsumptionConstant.userName, ConsumptionConstant.password);// 連線資料庫
			//Statement stat = conn.createStatement();//建立一個 Statement 物件來將 SQL 語句傳送到資料庫。
			PreparedStatement stat = conn.prepareStatement(sql);
			if(Func.isNotEmpty(map)){
				//餐別
				if(map.containsKey("mealType")){
					stat.setString(1, map.get("mealType"));
				}
				//消費時間
				if(map.containsKey("date")){
					stat.setDate(2,Date.valueOf(map.get("date")));//轉換成java sql型別
				}
			}

			ResultSet resultSet=stat.executeQuery();

			ResultSetMetaData md = resultSet.getMetaData();
			int columnCount = md.getColumnCount();
			while (resultSet.next()) {
				Map<String,Object> rowData = new HashMap();
				for (int i = 1; i <= columnCount; i++) {
					rowData.put(md.getColumnName(i), resultSet.getObject(i));
				}
				list.add(rowData);
			}
			System.out.println("list====="+list);
			resultSet.close();
		} catch (Exception e) {
			e.printStackTrace();
		}
     return list;
	}
}