package com.buy.bean.coin;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

import com.buy.bean.comm.database.DBConnect;
public class ConsumeSelectBean1 {
	public ConsumeSelectBean1(){		

	}
	public StringBuffer selectConsume(String userID) {
		String condition;		
			condition = "select count(userid) as num, productname , sum(price) as total from consume where userid = '"+userID+"' group by productname";		
		ResultSet rs = null;
		String name, coin, num;
		Statement sql = null;
		StringBuffer buffer = new StringBuffer();
		try {
			Connection conn = DBConnect.getConnection();
			sql = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,
					ResultSet.CONCUR_READ_ONLY);
			rs = sql.executeQuery(condition);
			while (rs.next()) {
				num = rs.getString(1);
				name = rs.getString(2);
				coin = rs.getString(3);
				buffer.append( num + "個" +name+" , "+"金額："+coin+"<br>");
			}
			rs.close();
			sql.close();
			conn.close();
		} catch (SQLException ex) {
			System.out.println("TradeDB SQLException: " + ex.getMessage());
			return new StringBuffer("查詢錯誤");
		}
		return buffer;
	}
}