OrientDBAppender.java 文件源码

/**
 * Method that creates query for OrientDB from the JSONObject event in the queue
 * and executes it in the database
 * @see {@link DataBaseAppender}{@link #saveQueue()} 
 */
@Override
protected void saveQueue() {
    // TODO Auto-generated method stub
    if (queue.size() == 0)
        return;
    StringBuffer cmd = new StringBuffer("begin\n");
    for (Object obj : queue) {
        cmd.append("insert into " + table + " content " + ((JSONObject) obj).toString() + "\n");
    }
    cmd.append("commit\n");
    //System.out.println(cmd);
    try
    {
        database.command(new OCommandScript("sql", cmd.toString())).execute();
    }
    catch(Exception e){
        errorHandler.error("Unexpected exception while saving events", e,
                ErrorCode.GENERIC_FAILURE);
    }
}