databasertx.java

腾讯RTX开发示例 结合本单位OA系统提供消息提醒功能

package Irtx;

import java.sql.Connection; 
import java.sql.DriverManager; 
import java.sql.PreparedStatement; 
import java.sql.ResultSet; 
import java.sql.Statement; 



public class  databaseRtx
{
	
	private String gvDriver = "";  
    private String gvUser = "sa"; //数据库访问用户 
    private String gvPassword = ""; //数据库访问密码 
    private static String message = "恭喜，数据库连接正常！";
    
    
   //记录rtx_SendIM中行总数
   int intRowCount;
    
   
    String redSQLStr = "SELECT id,rtx_num,name,title,process_inst_id,step_flag FROM rtx_SendIM";
    
    String insSQLStr = "INSERT INTO rtx_SendIM "+
                       "(id,rtx_num,name,title,process_inst_id,step_flag)"+  
                       "SELECT USERINFO_ID,rtx_num,USERINFO_NAME,'0','0','0' FROM UP_USERINFO";
                         
    String rowCountSQLStr=   "SELECT COUNT(*) FROM rtx_SendIM";


    //" id,rtx_num,process_inst_id,process_id,step_id,step_closedtype,step_startmode,app_name,enr_human,enr_org_unit,enr_time from enrol_flow";
    //String updataSQLStr=
    
    
    Connection conn = null;
    Statement st;
    ResultSet rs;
	public final String[] colHeads={"id","rtx_num","name","title","process_inst_id","step_flag"};
	//public final String[] colHeads={"id","rtx_num","process_inst_id","process_id","step_id","step_closedtype","step_startmode","app_name","enr_human","enr_org_unit","enr_time"};
			
	public Object[][] rtxSendIMdata=new Object[10000][6];
	public Object[][] rtxUserData=new Object[10000][6];
	public Object[][] rtxMofileData=new Object[10000][6];

	//链接数据库,并初始化数组变量
	public databaseRtx()
	 {
		try{
			 /**
              *  加载数据库驱动 
              *  DB_test 为数据库名称
              */
              //链接地址
              gvDriver="jdbc:jtds:sqlserver://localhost:1433;DatabaseName=eBuilder";
	          
              //链接驱动
			 Class.forName("net.sourceforge.jtds.jdbc.Driver");
			 //创建链接
			 conn =  DriverManager.getConnection(gvDriver, gvUser, gvPassword);
			 
			 //创建Statement对象
			 st = conn.createStatement();
				  
			 }catch(Exception a){
				 conn = null; 
				 message = a.toString();
				 } 
				 //return conn;

  }

  public void redRtx_SendIM(String redSQLStr)
    {

       try{
			 
			 
             //创建读取数据库结果集对象，sqlStr为读取SQL参数
			 //System.out.println( "aaaaaaaal!" );
			 
			 rs = st.executeQuery( redSQLStr );
			 
			 
			 int n=0;
			 
			 while(rs.next())
			    {
				   //System.out.println( "aaaaaaaal!"+n );
				   rtxSendIMdata[n][0]=rs.getString("id");
				   rtxSendIMdata[n][1]=rs.getString("rtx_num");
				   rtxSendIMdata[n][2]=rs.getString("name");
				   rtxSendIMdata[n][3]=rs.getString("title");
				   rtxSendIMdata[n][4]=rs.getString("process_inst_id");
				   rtxSendIMdata[n][5]=rs.getString("step_flag");
				   				   
				   //System.out.println( "bbbbbbbbb!" );
				   
				   n+=1;
				   }
				  
			 }catch(Exception a){
				 conn = null; 
				 message = a.toString();
				 } 
				 //return conn;
		
  }
  
   public void insRtx_SendIM(String insSQLStr)
    {

       try{
			 
			 st.executeUpdate( insSQLStr );
			 
			 rs = st.executeQuery( redSQLStr );
			 
			 
			 int n1=0;
			 
			 while(rs.next())
			    {
				   //System.out.println( "aaaaaaaal!"+n1 );
				   rtxSendIMdata[n1][0]=rs.getString("id");
				   rtxSendIMdata[n1][1]=rs.getString("rtx_num");
				   rtxSendIMdata[n1][2]=rs.getString("name");
				   rtxSendIMdata[n1][3]=rs.getString("title");
				   rtxSendIMdata[n1][4]=rs.getString("process_inst_id");
				   rtxSendIMdata[n1][5]=rs.getString("step_flag");
				   				   
				   //System.out.println( "bbbbbbbbb!" );
				   
				   n1+=1;
				   }
				  
			 }catch(Exception a){
				 conn = null; 
				 message = a.toString();
				 } 
				 //return conn;
		
	}
				 
	public int returnRowCount(String rowCountSQLStr)
    {

       try{
			 
			 intRowCount=st.executeUpdate( rowCountSQLStr );
			 
						 
				  
			 }catch(Exception a){
				 conn = null; 
				 message = a.toString();
				 } 
		
		return intRowCount;		 
				 
				 
	}			 
	
  
  
  
  
}