BlobUpload.java

Go to the documentation of this file.

// reads MCProcessType from DB, adds compatibility info to it 
// and writes it back to the DB

package cedar.jetweb.db;

import cedar.jetweb.model.MCProcessType;
import cedar.jetweb.JetWebConfig;
import cedar.jetweb.JetWebException;

import java.util.Arrays;
import java.util.Vector;

import java.sql.Statement;


public class BlobUpload{

    public static void main(String[] args){
    
    if(!Arrays.asList(args).contains("-ProcessId")||
       !Arrays.asList(args).contains("-Array")){

        System.out.println("entry not specified on the command line");

        return;

    }

    System.out.println("   Connecting to database...");

    JetWebConfig.init();

    DBConnectionManager connManager = new DBConnectionManager();
    String[] dbs = {DBConfig.JETWEB};
        connManager.init(dbs);

    DBObjectManager objManager = new DBObjectManager();
        objManager.passDBConnection(connManager);

    System.out.println("   ...got database");

    //Get the array from the command line:
    // first string in array is "["

    System.out.println("   Parsing array...");

    int arrayIndex = Arrays.asList(args).indexOf("-Array") + 2;

    Vector<Integer> data = new Vector<Integer>();
    

    String element  = args[arrayIndex];
    while(!element.equals("]")){

        data.add(new Integer(Integer.parseInt(element)));
        ++arrayIndex;
        element  = args[arrayIndex];
    }

    System.out.println("   ...got array");

    arrayIndex = Arrays.asList(args).indexOf("-ProcessId")+1;

    int procId = Integer.parseInt(args[arrayIndex]);

    System.out.println("   Getting exisiting process settings...");

    MCProcessType proc = new MCProcessType(procId);

    System.out.println("   ...got existing process");

    proc.setCompatibleProcesses(data);

    System.out.println("   Writing new process...");

    System.out.println("process type = "+proc.getProcessName());

    try{

        String cmd = "delete from process_type where process_id="+procId;

        Statement stmt = 
        connManager.getConnection(DBConfig.JETWEB).createStatement();

        stmt.execute(cmd);

        objManager.writeObject(proc, "process_type", DBConfig.JETWEB);
    }catch(Throwable err){
        System.out.println(err.getMessage());
    }
    System.out.println("");

    System.out.println("      ...finished");

    }


}

Generated Wed Jan 17 09:14:27 GMT 2007