serviceset.java

Email营销是在用户事先许可的前提下

package com.qq.content;
import java.sql.SQLException;
import java.util.ArrayList;

import javax.sql.rowset.CachedRowSet;
public class serviceSet {
	private static DBTool db=null;	
	private SqlChecker SC = new SqlChecker();
	static{
		try{
			db=new DBTool();
		}catch(Exception e){
			
		}
	}
	public serviceSet() throws Exception{
		if(db==null)db=new DBTool();
	}
	public boolean addService(String service_name,String chinese_name,String add_person){
		if(SC.check(service_name)!=0 || SC.check(chinese_name)!=0)return false;
		String sql="SELECT * FROM services_info WHERE service_status=9 AND service_name='"+service_name+"'";
		try {
			CachedRowSet crs=db.query(sql);
			if(crs.next()){
				sql="UPDATE services_info SET chinese_name='"+chinese_name+"',add_person='"+add_person+"',service_status=0 WHERE service_name='"+service_name+"'";
				System.out.println("SQL:"+sql);
				try {
					db.execute(sql);
					return true;
				} catch (Exception e) {
					e.printStackTrace();
					return false;
				}				
			}else{
				sql="INSERT INTO services_info VALUES('"+service_name+"','"+chinese_name+"','"+DATA.getDateTimeStr()+"','"+add_person+"',0,0,0,'')";
				System.out.println("SQL:"+sql);
				try {
					db.execute(sql);
					return true;
				} catch (Exception e) {
					e.printStackTrace();
					return false;
				}								
			}
		} catch (SQLException e1) {
			e1.printStackTrace();
		}
		return false;
	}
	
	static public String getChineseNameByServiceName(String name){
		
		String sql="SELECT chinese_name FROM services_info WHERE service_name='"+name+"'";
		System.out.println(sql);
		try {
			CachedRowSet crs=db.query(sql);
			while(crs.next()){
				return crs.getString(1);
			}
			return null;
		} catch (SQLException e) {
			e.printStackTrace();
			return null;
		}
		
	}
	
  public String[] getServicesNames(){		
		String name[]=new String[getServicesNumber()*2];
		int i=0;
		String sql="SELECT service_name,chinese_name FROM services_info WHERE service_status=0";
		System.out.println(sql);
		try {
			CachedRowSet crs=db.query(sql);
			while(crs.next()){
				name[i++]=crs.getString(1);
				name[i++]=crs.getString(2);
			}
		} catch (SQLException e) {
			e.printStackTrace();			
		}
		return name;
	}	
	
	static public int getServicesNumber(){
		String sql="SELECT COUNT(*) FROM services_info WHERE service_status=0";
		System.out.println(sql);
		try {
			CachedRowSet crs=db.query(sql);
			if(crs.next()){
				return crs.getInt(1);
			}else
				return 0;
		} catch (SQLException e) {
			e.printStackTrace();
			return 0;
		}
	}
	
	public boolean deleteService(String service_name){
		if(SC.check(service_name)!=0)return false;
		String sql="UPDATE services_info SET service_status=9 WHERE service_name='"+service_name+"'";
		System.out.println("SQL:"+sql);
		try {
			db.execute(sql);
		} catch (Exception e) {
			e.printStackTrace();
		}
		return true;
	 	
	}
	
	public ArrayList getServiceList(){
		ArrayList al=new ArrayList();
		String sql="SELECT * FROM services_info";
		System.out.println("SQL:"+sql);
		/*
  `service_name` varchar(16) NOT NULL default '0',
  `chinese_name` varchar(100) NOT NULL default '',
  `add_time` varchar(30) NOT NULL default '0000-00-00',
  `add_person` varchar(100) NOT NULL default '',
  `sub_times` int(11) NOT NULL default '0',
  `quit_times` int(11) NOT NULL default '0',
  `service_status` int(1) NOT NULL default '0',		 * 
		 */
		try {
			CachedRowSet crs=db.query(sql);
			while(crs.next()){
				ArrayList alx=new ArrayList();
				alx.add(crs.getString("service_name"));
				alx.add(crs.getString("chinese_name"));
				alx.add(crs.getString("add_time"));
				alx.add(crs.getString("add_person"));
				alx.add(crs.getString("sub_times"));
				alx.add(crs.getString("quit_times"));
				String st="未知";
				if(crs.getString("service_status").equals("0"))st="正常";
				else st="已删除";
				alx.add(st);
				al.add(alx);
			}			
		} catch (Exception e) {
			e.printStackTrace();			
		}		
		return al;
	}
	/**
	 * @param args
	 */
	public static void main(String[] args) {

	}

}