import java.io.*;
import javax.servlet.*;
import java.sql.*;

import Base.Action.*;
import Base.DataBean.*;
/**
 * 用于update、delect、insert等的模塊 modular
 * 
 */
public class SqlExecuteAction extends Action
{ 
        DefaultDataBean m_dBean = null;
        //交易處理的入口函數，
        //參數：  DefaultDataBean類的實例
        //返回值：0 - 出錯，錯誤原因放在key: Action.perform.errReason, value:為String類
        //                  錯誤代碼放在key: Action.perform.errCode,   value:為Integer類
        //        1 - 成功，可以繼續執行后一個交易
        public int perform(DefaultDataBean dBean)  throws IOException, ServletException
        {
             int iPos[],iOccur=0;
             ResultSet rs=null; 
             
             try{   
                 String strActionName = dBean.getAttributeStr(m_servlet.ACTION_NAME_PREFIX);
                 if(strActionName == null) strActionName = new String("");
                 m_dBean = dBean;
        	 String paraName = m_servlet.ACTION_PARA_PREFIX + "sql";
        	 String paraSqlStr = dBean.getAttributeStr(paraName);
        	 if( paraSqlStr==null || paraSqlStr.length() == 0 )
        	 {
        	 	setError(1000,"no sql string found");
        	 	return 0;
        	 }
        	 //m_servlet.log(2,"para Sql String :[" +  paraSqlStr+"]");
        	 
        	 //find how many ? characters in  paraSqlStr
        	 for( int i=0; i < paraSqlStr.length(); i++)
        	 {
        	 	i = paraSqlStr.indexOf('?',i);
        	 	if( i == -1 ) break;
        	 	iOccur ++;
        	 }
        	 
        	 //find Sql paras in  xml
        	 String[] sqlParaValue = new String[iOccur];
        	 for( int i=0; i< iOccur; i++)
        	 {
        	 	paraName = m_servlet.ACTION_PARA_PREFIX + i;
        	 	String name = dBean.getAttributeStr(paraName);
        	 	sqlParaValue[i] = dBean.getAttributeStr(name);
        	 	
        	 	m_servlet.log(2,"name:"+paraName+" val:"+sqlParaValue[i]+" i:"+ i);
        	 }
        	 if( iOccur > 0 )
        	 {
        	 	int iRet = 0;
        	 	StringBuffer strBuf = new StringBuffer(paraSqlStr); 
        	 	for( int i=0; i< iOccur; i++)
        	        {
        	        	iRet = strBuf.toString().indexOf('?',iRet);
        	        	strBuf = strBuf.replace(iRet,iRet+1,sqlParaValue[i]);
        	        	iRet += sqlParaValue[i].length();
        	        }
        	        paraSqlStr = strBuf.toString();
        	 }
			 	 
        	 m_servlet.log(2,"  Sql :[" +  paraSqlStr+"]");
        	 Statement stmt = (Statement)dBean.getAttribute("Action.perform.Statement");
        	 if(stmt == null ) { setError(1000,"數據庫連接失敗 (no Statement object)"); return 0; }
        	 int iRet = stmt.executeUpdate(paraSqlStr); 
                 //全縣重新加載
				 if(paraSqlStr.indexOf("kjc_right")!=-1
					 ||paraSqlStr.indexOf("kjc_role")!=-1
					 ||paraSqlStr.indexOf("kjc_people")!=-1)
				 {
					 com.db.StaticBean.init();
					System.out.println("&&&&&&&&&&&&&&數據庫人員權限變動");
				 }
                 m_servlet.log(2,"  executeUpdate return " + iRet);
             }catch(Exception e){
   	         setError( 1000 , e.getMessage() );
   	      m_servlet.log("SqlExecuteAction:",e);
        	 return 0;
   	     }
   	     
             return 1;
        }
        
        void setError(int errCode ,String errReason)
        {
             if(m_dBean != null)
             {
             	m_dBean.putAttribute("Action.perform.errReason",errReason );
             	m_dBean.putAttribute("Action.perform.errCode",new Integer(errCode) );
             	m_servlet.log(2,"Action report error: " + errReason); 
             }
             return;
        }
 
    
}