Titanium Database

function savePollingRecord(respondentID, pollingID, questionID, answerSet){

    var db = Titanium.Database.open('pollingdb');

    db.execute('CREATE TABLE IF NOT EXISTS MPS_POLLING (RESPONDENT_ID TEXT, POLLING_ID INTEGERE, QUESTION_ID INTEGER, ANSWER_ID INTEGER)');

    db.execute('DELETE FROM MPS_POLLING WHERE RESPONDENT_ID=? AND POLLING_ID=? AND QUESTION_ID=?', respondentID, pollingID, questionID);

    for(a in answerSet){

        db.execute('INSERT INTO MPS_POLLING(RESPONDENT_ID, POLLING_ID, QUESTION_ID, ANSWER_ID) VALUES(?,?,?,?)', respondentID, pollingID, questionID,answerSet[a]);

        Ti.API.info('DB updated with rowsAffected='+db.rowsAffected);

    }    

    db.close();

}

function retrievePollingRecordByQuestionID(respondentID, pollingID, questionID){

    var rtnAnswerSet=[];

    var db = Titanium.Database.open('pollingdb');

    db.execute('CREATE TABLE IF NOT EXISTS MPS_POLLING (RESPONDENT_ID TEXT, POLLING_ID INTEGERE, QUESTION_ID INTEGER, ANSWER_ID INTEGER)');

    var rows = db.execute('SELECT ANSWER_ID FROM MPS_POLLING WHERE RESPONDENT_ID=? AND POLLING_ID=? AND QUESTION_ID=?', respondentID, pollingID, questionID);

    while (rows.isValidRow())

    {

        rtnAnswerSet.push(rows.field(0));

        rows.next();

    }

    rows.close();

    db.close();

    return rtnAnswerSet;

}