Package cx.fbn.nevernote.sql.driver

Examples of cx.fbn.nevernote.sql.driver.NSqlQuery


  }

  // does a record exist?
  public String setNotebookGuid(String shareKey, String notebookGuid) {
    
    NSqlQuery query = new NSqlQuery(db.getConnection());
   
    query.prepare("Update LinkedNotebook set notebookGuid=:notebookGuid where shareKey=:shareKey");
    query.bindValue(":notebookGuid", notebookGuid);
    query.bindValue(":shareKey", shareKey);
    if (!query.exec())
      logger.log(logger.EXTREME, "Linked notebook SQL retrieve by share name has failed.");
    String val = null;
    if (query.next())
      val = query.valueString(0);
    return val;
  }
View Full Code Here


    return val;
  }
  // set sync date
  public String setLastSequenceDate(String guid, long date) {
    
    NSqlQuery query = new NSqlQuery(db.getConnection());
   
    query.prepare("Update LinkedNotebook set lastsequencedate=:date where guid=:guid");
    query.bindValue(":date", date);
    query.bindValue(":guid", guid);
    if (!query.exec())
      logger.log(logger.EXTREME, "Linked notebook SQL retrieve by share name has failed.");
    String val = null;
    if (query.next())
      val = query.valueString(0);
    return val;
  }
View Full Code Here

    return val;
  }
  // set sync number
  public String setLastSequenceNumber(String guid, int number) {
    
    NSqlQuery query = new NSqlQuery(db.getConnection());
   
    query.prepare("Update LinkedNotebook set lastsequencenumber=:number where guid=:guid");
    query.bindValue(":number", number);
    query.bindValue(":guid", guid);
    if (!query.exec())
      logger.log(logger.EXTREME, "Linked notebook SQL retrieve by share name has failed.");
    String val = null;
    if (query.next())
      val = query.valueString(0);
    return val;
  }
View Full Code Here

 
  // Get a list of linked notebooks that need to be updated
  public List<String> getDirtyGuids() {
    List<String> index = new ArrayList<String>();
    boolean check; 
        NSqlQuery query = new NSqlQuery(db.getConnection());
               
    check = query.exec("Select guid from LinkedNotebook where isDirty = true");
    if (!check)
      logger.log(logger.EXTREME, "LinkedNotebook SQL retrieve has failed in getdirtyIds.");
    while (query.next()) {
      index.add(query.valueString(0));
   
    return index; 
  }
View Full Code Here

    }   
    if (!resourceDbExists) {
      createResourceTables();
      if (dbTableExists("NoteResources")) {
        // Begin migration of database
        NSqlQuery query = new NSqlQuery(resourceConn);
        String linkcmd = "create linked table oldnoteresources "+
            "('org.h2.Driver', '"+url+"', '"+userid+"', '"+passwordString+"', 'NoteResources')";
        query.exec(linkcmd);
        query.exec("insert into noteresources (select * from oldnoteresources)");
        query.exec("Drop table oldnoteresources;");
        query.exec("Update noteresources set indexneeded='true'");
       
      }
    }
    if (!indexDbExists)  {
      createIndexTables();
View Full Code Here

      executeSql("update note set attributeContentClass = ''");
    }
  }
 
  public void executeSql(String sql) {
    NSqlQuery query = new NSqlQuery(conn);
    query.exec(sql)
  }
View Full Code Here

  //****************************************************************
  //* Begin/End transactions
  //****************************************************************
  public void beginTransaction() {
    commitTransaction();
        NSqlQuery query = new NSqlQuery(getConnection());                         
    if (!query.exec("Begin Transaction"))
      logger.log(logger.EXTREME, "Begin transaction has failed: " +query.lastError());

  }
View Full Code Here

    if (!query.exec("Begin Transaction"))
      logger.log(logger.EXTREME, "Begin transaction has failed: " +query.lastError());

  }
  public void commitTransaction() {
        NSqlQuery query = new NSqlQuery(getConnection());
                         
    if (!query.exec("Commit"))
      logger.log(logger.EXTREME, "Transaction commit has failed: " +query.lastError());
  }
View Full Code Here

  //****************************************************************
  //* Check if a table exists
  //****************************************************************
  public boolean dbTableExists(String name) {
        NSqlQuery query = new NSqlQuery(getConnection());
        query.prepare("select TABLE_NAME from INFORMATION_SCHEMA.TABLES where TABLE_NAME=:name");
        query.bindValue(":name", name.toUpperCase());
        query.exec();
        if (query.next())
          return true;
        else
          return false;
  }
View Full Code Here

    dbName = name;
  }

  // Create the table
  public void createTable(boolean addDefaulte) {
    NSqlQuery query = new NSqlQuery(db.getConnection());
        logger.log(logger.HIGH, "Creating table "+dbName+"...");
        if (!query.exec("Create table "+dbName+" (guid varchar primary key, " +
            "sequence integer, " +
            "name varchar, "+
            "defaultNotebook varchar, "+
            "serviceCreated timestamp, " +
            "serviceUpdated timestamp, "+
            "published boolean, "+
            "isDirty boolean, "+
            "autoEncrypt boolean, "+
            "local boolean, "+
            "archived boolean)"))             
          logger.log(logger.HIGH, "Table "+dbName+" creation FAILED!!!");  
        Notebook newnote = new Notebook();
        newnote.setDefaultNotebook(true);
        newnote.setName("My Notebook");
        newnote.setPublished(false);
        newnote.setGuid("1");
       
        // Setup an initial notebook
    SimpleDateFormat simple = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.S");
        query = new NSqlQuery(db.getConnection());
    query.prepare("Insert Into "+dbName+" (guid, sequence, name, defaultNotebook, "
        +"serviceCreated, serviceUpdated, published, "  
        + "isDirty, autoEncrypt, "
        + "local, archived) Values("
        +":guid, :sequence, :name, :defaultNotebook,  "
        +":serviceCreated, :serviceUpdated, :published, "
        +":isDirty, :autoEncrypt, "
        +":local, false)");
    query.bindValue(":guid", newnote.getGuid());
    query.bindValue(":sequence", newnote.getUpdateSequenceNum());
    query.bindValue(":name", newnote.getName());
    query.bindValue(":defaultNotebook", newnote.isDefaultNotebook());
   
    StringBuilder serviceCreated = new StringBuilder(simple.format(newnote.getServiceCreated()));     
    StringBuilder serviceUpdated = new StringBuilder(simple.format(newnote.getServiceUpdated()));
    if (serviceUpdated.toString() == null)
      serviceUpdated = serviceCreated;
    query.bindValue(":serviceCreated", serviceCreated.toString());
    query.bindValue(":serviceUpdated", serviceCreated.toString());
    query.bindValue(":published",newnote.isPublished());
   
    query.bindValue(":isDirty", true);
    query.bindValue(":autoEncrypt", false);
    query.bindValue(":local", false);

    boolean check = query.exec();
    if (!check) {
      logger.log(logger.MEDIUM, "Initial "+dbName+" Table insert failed.");
      logger.log(logger.MEDIUM, query.lastError().toString());
    }

    
  }
View Full Code Here

TOP

Related Classes of cx.fbn.nevernote.sql.driver.NSqlQuery

Copyright © 2018 www.massapicom. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.