/*
 * 創(chuàng)建日期 2008-3-12
 *
 * TODO 要更改此生成的文件的模板，請(qǐng)轉(zhuǎn)至
 * 窗口 － 首選項(xiàng) － Java － 代碼樣式 － 代碼模板
 */
package appsm.util;

import java.sql.ResultSet;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import javax.swing.JOptionPane;
import appsm.model.*;

/**
 * @author bjq
 *
 * TODO 要更改此生成的類型注釋的模板，請(qǐng)轉(zhuǎn)至
 * 窗口 － 首選項(xiàng) － Java － 代碼樣式 － 代碼模板
 */
public class JdbcAdapter {
	public static Connection con;
	public static PreparedStatement pstmt;
    private static  String infoStr = null;
    private static ResultSet rs=null;
    private boolean validateID(String id,String tname,String idvalue){
        String sqlStr=null;
        sqlStr="select count(*) from "+tname+" where "+id+"='"+idvalue+"'";
    try{
        Connection con=CommonaJdbc.connection;
        pstmt=con.prepareStatement(sqlStr);
        rs=null;
		rs=pstmt.executeQuery();
       
        if(rs.next()){
            if(rs.getInt(1)>0)
            {rs.close();
            pstmt.close();
            return true;
            }
            }
		
        
        }catch(java.sql.SQLException sql){
            sql.printStackTrace();
            return false;
            }
        return false;
    }
    /******************************數(shù)據(jù)驗(yàn)證功能************************************/ 
    private boolean AdapterObject(String sqlState){
        boolean flag=false;
        try{
           con=CommonaJdbc.connection;
           pstmt=con.prepareStatement(sqlState);
            pstmt.execute();
            flag=true;
         
            if(infoStr!=null)JOptionPane.showMessageDialog(null,infoStr+"數(shù)據(jù)成功!!","系統(tǒng)提示您",JOptionPane.INFORMATION_MESSAGE);
            pstmt.close();
            }catch(SQLException sql){
                flag=false;
                sql.printStackTrace();
                }
            
            return flag;
        }
    /*********************************執(zhí)行操作**********************/
    public boolean InsertSP(Obj_shangpin objshangpin){
        String sql=null;
        if(validateID("goodsID","tb_Shangpin",objshangpin.getgoodsID())){
            JOptionPane.showMessageDialog(null,"數(shù)據(jù)已存在!!","系統(tǒng)提示您",JOptionPane.INFORMATION_MESSAGE);   
        }
        else{
            sql="insert into  tb_Shangpin (goodsID,goodsName,goodsPrice,goodsDanwei,goodsNumber,goodsKucun,goodsSell)  values ('"+objshangpin.getgoodsID()
            +"','"+objshangpin.getgoodsName()
            +"','"+objshangpin.getgoodsPrice()
            +"','"+objshangpin.getgoodsDanwei()
            +"','"+objshangpin.getgoodsNumber()
            +"','"+objshangpin.getgoodsKucun()
            
            +"',0)";
            infoStr="添加商品信息";
            }
        return AdapterObject(sql);
       
        }
    /********************************商品表添加操作****************************/
    public boolean InsertXS(Obj_sell objsell){
        String sql=null;
        
        sql="INSERT into tb_sell values('"+objsell.getgoodsID()
            +"','"+objsell.getgoodsName()
            +"','"+objsell.getgoodsPrice()
            +"','"+objsell.getgoodsNumber()
            +"','"+objsell.getgoodsTime()
			+"')";
            
            infoStr=null;
        
    return AdapterObject(sql);
    }
    /***************************銷售表添加操作****************************/

    public boolean InsertYH(Obj_user objuser){
        String sql=null;
        if(validateID("userID","tb_user",objuser.getuserID())){
            JOptionPane.showMessageDialog(null,"用戶已存在!!","系統(tǒng)提示您",JOptionPane.INFORMATION_MESSAGE);   
        }
        else{
            sql="INSERT INTO tb_user VALUES('"+objuser.getuserID()
            +"','"+objuser.getuserName()
            +"','"+objuser.getuserPass()
            +"','"+objuser.getuserqx()
            +"')";
            infoStr="添加用戶信息";
            }
        return AdapterObject(sql);
        }
    /**********************用戶表添加操作**********************/
    public boolean UpdateSP(Obj_shangpin objshangpin){
        String sql=null;
        if(validateID("goodsID","tb_Shangpin",objshangpin.getgoodsID())){
            sql="   update tb_Shangpin set goodsName='"+objshangpin.getgoodsName()+"'where goodsID='"+objshangpin.getgoodsID()
            	+"' update tb_Shangpin set goodsID='"+objshangpin.getgoodsID()+"'where goodsID='"+objshangpin.getgoodsID()
				+"' update tb_Shangpin set goodsPrice='"+objshangpin.getgoodsPrice()+"'where goodsID='"+objshangpin.getgoodsID()
				+"' update tb_Shangpin set goodsDanwei='"+objshangpin.getgoodsDanwei()+"'where goodsID='"+objshangpin.getgoodsID()
				+"' update tb_Shangpin set goodsNumber='"+objshangpin.getgoodsNumber()+"'where goodsID='"+objshangpin.getgoodsID()
				+"' update tb_Shangpin set goodsKucun='"+objshangpin.getgoodsKucun()
				+"' where goodsID='"+objshangpin.getgoodsID()+"'";
            infoStr="更新商品信息";
            }
        else{
            JOptionPane.showMessageDialog(null,"商品不存在!!","系統(tǒng)提示您",JOptionPane.INFORMATION_MESSAGE);   
            }
        return AdapterObject(sql);
        }
   /*****************************商品表修改********************************/
    public boolean UpdataYH(Obj_user objuser){
        String sql=null;
        if(validateID("userID","tb_user",objuser.getuserID())){
            sql="UPDATE tb_user SET userID='"+objuser.getuserID()
            +"',userName='"+objuser.getuserName()
            +"',userPass='"+objuser.getuserPass()
            +"',userqx='"+objuser.getuserqx()
            +"'WHERE userID='"+objuser.getuserID().trim()+"'";
            infoStr="更新用戶信息";
            }
        else{
            JOptionPane.showMessageDialog(null,"用戶不存在!!","系統(tǒng)提示您",JOptionPane.INFORMATION_MESSAGE);   
            }
        return AdapterObject(sql);
        }
    /****************************用戶修改**********************************/
   public boolean Delet(String sql){
   	infoStr="刪除信息";
       return AdapterObject(sql);
       }
   /************刪除*************/
   public boolean Clear(String sql){
   	    infoStr=null;
       return AdapterObject(sql);
       }
}