Examples of sos.connection.SOSConnection.execute()

sos.connection.SOSConnection.execute()
executes a statement @param query SQL query @throws java.lang.Exception @see #executeQuery(String) @see #get()

            connection = sos.connection.SOSConnection.createInstance(getJobProperties().getProperty("config"));
              connection.connect();
            new_connection = true;
        } else if (getJobProperties().getProperty("database") != null) {
              database = getJobProperties().getProperty("database").toString();
              if (database != null && database.length()>0) connection.execute("USE " + database);
              getLogger().info("database changed to: " + database);
          }
      if (!(connection instanceof SOSMySQLConnection)){
            getLogger().warn("This Job only works with MySQL databases.");
            return false;

View Full Code Here

          }
      
      if (getJobProperties().getProperty("flush_tables") != null 
                && getJobProperties().getProperty("flush_tables").toString().equalsIgnoreCase("yes")) {
                getLogger().info("tables will be flushed to publish optimizations");
                connection.execute("FLUSH TABLES");
        }
      
    } catch (Exception e){
      getLogger().error ("maintenance monitor failed: " + e);
          return false;

View Full Code Here

      }    
      catch (Exception e) {
          throw new Exception("error occurred establishing database connection: " + e.getMessage());
      }
      userConnection.connect();
      if (schema!=null && schema.length()>0) userConnection.execute("use "+schema);
      userConnection.commit();
    return userConnection;
    
  }

View Full Code Here

TOP

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.