Examples of dowork()


Examples of org.apache.hadoop.hbase.util.HBaseFsck.doWork()

    HBaseFsck fsck = new HBaseFsck(conf);
    fsck.connect();
    fsck.displayFullReport(); // i.e. -details
    fsck.setTimeLag(0);
    fsck.setFixErrors(fix);
    fsck.doWork();
    return fsck;
  }

  public static void assertNoErrors(HBaseFsck fsck) throws Exception {
    List<ERROR_CODE> errs = fsck.getErrors().getErrorList();
View Full Code Here

Examples of org.apache.jcs.JCSvsHashtablePerformanceTest.doWork()

     * @param args
     */
    public static void main( String args[] )
    {
        JCSvsHashtablePerformanceTest test = new JCSvsHashtablePerformanceTest( "command" );
        test.doWork();
    }

}
View Full Code Here

Examples of org.apache.jcs.JCSvsHashtablePerformanceTest.doWork()

     * @param args
     */
    public static void main( String args[] )
    {
        JCSvsHashtablePerformanceTest test = new JCSvsHashtablePerformanceTest( "command" );
        test.doWork();
    }

}
View Full Code Here

Examples of org.hibernate.Session.doWork()

    private void updateBlobs(final boolean isDispose) {
        final Set<HasBlob<?>> updates = (Set<HasBlob<?>>) env.get(HasBlob.GORM_UPDATE_SET);
        configureEnvironment();
        Session session = GrailsIntegration.getCurrentSession();
       
        session.doWork(new Work() {
            @Override
            public void execute(Connection conn) throws SQLException {
                boolean hasStoredKSession = false;
                for (final HasBlob<?> hasBlob : updates) {
                    if (!hasBlob.isDeleted()) {
View Full Code Here

Examples of org.hibernate.Session.doWork()

  }

  public void testGeneralUsage() throws Throwable {
    Session session = openSession();
    session.beginTransaction();
    session.doWork(
        new Work() {
          public void execute(Connection connection) throws SQLException {
            // in this current form, users must handle try/catches themselves for proper resource release
            Statement statement = null;
            try {
View Full Code Here

Examples of org.hibernate.Session.doWork()

  public void testSQLExceptionThrowing() {
    Session session = openSession();
    session.beginTransaction();
    try {
      session.doWork(
          new Work() {
            public void execute(Connection connection) throws SQLException {
              Statement statement = null;
              try {
                statement = connection.createStatement();
View Full Code Here

Examples of org.hibernate.Session.doWork()

  }

  public void testDialectGetColumnAliasExtractor() throws Exception {
    Session session = openSession();
    session.beginTransaction();
    session.doWork(
        new Work() {
          public void execute(Connection connection) throws SQLException {
            PreparedStatement ps = connection.prepareStatement( QUERY_STRING );
            ResultSet rs = ps.executeQuery();
            try {
View Full Code Here

Examples of org.hibernate.Session.doWork()

  public void testCreateAndDelete() {
    Date now = new Date();

    Session s = openSession();
    s.doWork(
        new Work() {
          public void execute(Connection connection) throws SQLException {
            // id -> java.util.Date (DATE - becase of explicit TemporalType)
            validateColumn( connection, "ID", java.sql.Types.DATE );
View Full Code Here

Examples of org.hibernate.Session.doWork()

            throw new JizzBlobException("Failed to unwrap Hibernate Session "
                    + "from JPA EntityManager: " + th.getMessage(), th);
        }

        try {
            session.doWork(new org.hibernate.jdbc.Work() {
                @Override
                public void execute(Connection connection) throws SQLException {
                    try {
                        work.execute(connection);
                    } catch (Throwable th) {
View Full Code Here

Examples of org.hibernate.engine.transaction.IsolatedWork.doWork()

      else {
        Isolater.doNonTransactedWork( work, session );
      }
    }
    else {
      work.doWork( session.getJDBCContext().getConnectionManager().getConnection() );
      session.getJDBCContext().getConnectionManager().afterStatement();
    }
  }

  protected void dropTemporaryTableIfNecessary(final Queryable persister, final SessionImplementor session) {
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.