基于Java的在线电影院售票平台设计源码

package dao; import dao.db.Builder; import util.Info; import util.StringUtil; import java.sql.*; import java.util.*; public class Query { protected String mName = ""; protected HashMap mOption = null; protected String pk = "id"; protected HashMap mData = null; protected Builder builder = null; public static HashMap tableFields = new HashMap(); public Query() { reset(); } public Query(String name) { reset(); setName(name); } protected Query reset() { mName = ""; mOption = null; mOption = new HashMap(); mData = new HashMap(); builder = Builder.make(new CommDAO().getConn()); if(tableFields == null) { tableFields = new HashMap(); } return this; } public Query inc(String field , int step) { if(step<1)step = 1; ArrayList list = new ArrayList(); list.add("inc"); list.add(step); mData.put(field , list); return this; } public Query dec(String field , int step) { if(step<1)step = 1; ArrayList list = new ArrayList(); list.add("dec"); list.add(step); mData.put(field , list); return this; } public boolean setInc(String field) { return setInc(field ,1); } public boolean setInc(String field , String step) { return inc(field , Integer.valueOf(step).intValue()).update(); } public boolean setInc(String field , int step) { return inc(field , step).update(); } public boolean setDec(String field ) { return setDec(field , 1); } public boolean setDec(String field , String step) { return dec(field , Integer.valueOf(step).intValue()).update(); } public boolean setDec(String field , int step) { return dec(field , step).update(); } public boolean setField(String field , Object step) { mData.put(field , step); return update(); } public HashMap getData() { return mData; } public boolean update() { return update(null); } public boolean update( HashMap updateData ) { if(updateData != null){ mData.putAll(updateData); } String sql = builder.buildUpdate(this); executeInsert(sql); return true; } public Query data(Map data) { mData.putAll(data); return this; } public Query data(String name , String value) { mData.put(name , value); return this; } public Query data(String name , int value) { mData.put(name , value); return this; } public Query data(String name , long value) { mData.put(name , value); return this; } public Query data(String name , float value) { mData.put(name , value); return this; } public Query data(String name , double value) { mData.put(name , value); return this; } public Query data(String name , boolean value) { mData.put(name , value ? 1 : 0); return this; } public int insert(HashMap insertData ){ return insert(insertData , false); } public int insert(HashMap insertData , boolean replace) { if(insertData != null){ mData.putAll(insertData); } String sql = builder.buildInsert(this , replace); return executeInsert(sql); } public String getPk() { return pk; } public void setPk(String pk) { this.pk = pk; } protected void finalize() { //Statement st = conn.createStatement(); //System.out.print(sql); //ResultSet rs //super.finalize(); free(); } /** * 释放资源 */ public void free() { // 释放rs for(int i=0;i<resultSetList.size();i++){ Object os = resultSetList.get(i); try{ if(os instanceof Statement){ Statement st = ((Statement) os); st.close(); }else if(os instanceof ResultSet){ ((ResultSet) os).close(); } }catch (SQLException e){ } } resultSetList.clear(); } public Query setName(String name) { mName = name; return this; } public String getName() { return mName; } public Query setAttribute(String name , Object value) { getOptionHashMap("data").put(name , value); return this; } public Object getAttribute(String name) { return getOptionHashMap("data").get(name); } public Query field() { return field("*"); } public Query field(String field) { getOptionArrayList("field").add(field); return this; } public Query table(String nTable) { getOptionArrayList("table").add(nTable); return this; } public Query table(String nTable , String alias) { getOptionArrayList("table").add(nTable+" "+alias); return this; } public Query limit(int nLimit) { //getOptionHashMap("limit").put("limit" , String.valueOf(nLimit)); return limit(String.valueOf(nLimit)); } public Query limit(int offset , int nLimit) { return limit(String.valueOf(offset) , String.valueOf(nLimit)); } public Query lock(boolean lock ) { return this.lock(lock ? " FOR UPDATE " : ""); } public Query lock(String lock) { getOption().put("lock" , lock); return this; } public Query limit(String nLimit) { if(nLimit.indexOf(",") != -1){ String[] list = nLimit.split(","); return limit(list[0] , list[1]); } getOptionHashMap("limit").put("limit" , nLimit); return this; } public Query limit(String offset , String nLimit) { HashMap map = getOptionHashMap("limit"); map.put("limit" , nLimit); map.put("offset" , offset); return this; } public HashMap find(int id) { where(pk , String.valueOf(id)); return find(); } public HashMap find(String id) { where(pk , id); return find(); } public HashMap find() { //limit(1); String sql = builder.buildSelect(this); ResultSet rs = query(sql); QueryData data = fetch(rs); return data; } protected double total(String f , String func) { String ifnull = builder.parseIfNull(func+"("+f+")" , "0"); String field = ifnull+" count"; if(mOption.containsKey("field")){ getOptionArrayList("field").clear(); } getOptionArrayList("field").add(field); HashMap data = find(); if(data.containsKey("count")){ String count = data.get("count").toString(); return Double.valueOf(count).doubleValue(); } return 0; } public double sum(String field) { return total(field , "SUM"); } public double avg(String field) { return total(field , "AVG"); } public double max(String field){ return total(field , "MAX"); } public double min(String field) { return total(field , "MIN"); } public long count() { return count(null); } public long count( String field ) { if(field == null){ if(mOption.containsKey("alias")){ field = "count("+mOption.get("alias")+".id) count"; }else{ field = "count(*) count"; } }else{ field = "count("+field+") count"; } if(mOption.containsKey("field")){ mO