Revert "add info" (#75)

Revert "add info (#74)" This reverts commit 04a17a7.
vesoft-inc · Dec 9, 2022 · dad7c36 · dad7c36
1 parent 04a17a7
commit dad7c36
Show file tree

Hide file tree

Showing 4 changed files with 1 addition and 24 deletions.
diff --git a/...g/ldbcouncil/snb/impls/workloads/nebula/operationhandlers/NebulaListOperationHandler.java b/...g/ldbcouncil/snb/impls/workloads/nebula/operationhandlers/NebulaListOperationHandler.java
@@ -26,7 +26,6 @@ public void executeOperation(TOperation operation, NebulaDbConnectionState state
         final String queryString = getQueryString(state, operation);
         state.logQuery(operation.getClass().getSimpleName(), queryString);
         final ResultSet result;
-        long startTime = System.currentTimeMillis();
         try {
             result = session.execute(queryString);
             if (state.isPrintErrors() && !result.isSucceeded()) {
@@ -47,11 +46,6 @@ public void executeOperation(TOperation operation, NebulaDbConnectionState state
 
         } catch (Exception e) {
             throw new DbException(e);
-        } finally {
-            long threadID = Thread.currentThread().getId();
-            long consumeTime = (System.currentTimeMillis() - startTime) / 1000;
-            System.out.println("Query SimpleName : " + operation.getClass().getSimpleName());
-            System.out.println("threadID : " + threadID + " startTime : " + startTime / 1000 + " consumeTime : " + consumeTime);
         }
     }
 

diff --git a/...il/snb/impls/workloads/nebula/operationhandlers/NebulaMultipleUpdateOperationHandler.java b/...il/snb/impls/workloads/nebula/operationhandlers/NebulaMultipleUpdateOperationHandler.java
@@ -16,7 +16,6 @@ public abstract class NebulaMultipleUpdateOperationHandler<TOperation extends Op
     @Override
     public void executeOperation(TOperation operation, NebulaDbConnectionState state, ResultReporter resultReporter) throws DbException {
         Session session = state.getSession();
-        long startTime = System.currentTimeMillis();
         try {
             List<String> queryStrings = getQueryString(state, operation);
             for (String queryString : queryStrings) {
@@ -28,11 +27,6 @@ public void executeOperation(TOperation operation, NebulaDbConnectionState state
             }
         } catch (Exception e) {
             throw new DbException(e);
-        } finally {
-            long threadID = Thread.currentThread().getId();
-            long consumeTime = (System.currentTimeMillis() - startTime) / 1000;
-            System.out.println("Query SimpleName : " + operation.getClass().getSimpleName());
-            System.out.println("threadID : " + threadID + " startTime : " + startTime / 1000 + " consumeTime : " + consumeTime);
         }
         resultReporter.report(0, LdbcNoResult.INSTANCE, operation);
     }

diff --git a/...council/snb/impls/workloads/nebula/operationhandlers/NebulaSingletonOperationHandler.java b/...council/snb/impls/workloads/nebula/operationhandlers/NebulaSingletonOperationHandler.java
@@ -16,10 +16,10 @@ public abstract class NebulaSingletonOperationHandler <TOperation extends Operat
     @Override
     public void executeOperation(TOperation operation, NebulaDbConnectionState state, ResultReporter resultReporter) throws DbException {
         Session session = state.getSession();
-        long startTime = System.currentTimeMillis();
         try {
             TOperationResult tuple = null;
             int resultCount = 0;
+
             final String queryString = getQueryString(state, operation);
             state.logQuery(operation.getClass().getSimpleName(), queryString);
             final ResultSet result = session.execute(queryString);
@@ -44,11 +44,6 @@ public void executeOperation(TOperation operation, NebulaDbConnectionState state
             resultReporter.report(resultCount, tuple, operation);
         } catch (Exception e) {
             throw new DbException(e);
-        } finally {
-            long threadID = Thread.currentThread().getId();
-            long consumeTime = (System.currentTimeMillis() - startTime) / 1000;
-            System.out.println("Query SimpleName : " + operation.getClass().getSimpleName());
-            System.out.println("threadID : " + threadID + " startTime : " + startTime / 1000 + " consumeTime : " + consumeTime);
         }
     }
 

diff --git a/...ldbcouncil/snb/impls/workloads/nebula/operationhandlers/NebulaUpdateOperationHandler.java b/...ldbcouncil/snb/impls/workloads/nebula/operationhandlers/NebulaUpdateOperationHandler.java
@@ -14,7 +14,6 @@ public abstract class NebulaUpdateOperationHandler <TOperation extends Operation
     @Override
     public void executeOperation(TOperation operation, NebulaDbConnectionState state, ResultReporter resultReporter) throws DbException {
         Session session = state.getSession();
-        long startTime = System.currentTimeMillis();
             try {
                 final String queryString = getQueryString(state, operation);
                 state.logQuery(operation.getClass().getSimpleName(), queryString);
@@ -24,11 +23,6 @@ public void executeOperation(TOperation operation, NebulaDbConnectionState state
                 }
             } catch (Exception e) {
                 throw new DbException(e);
-            } finally {
-                long threadID = Thread.currentThread().getId();
-                long consumeTime = (System.currentTimeMillis() - startTime) / 1000;
-                System.out.println("Query SimpleName : " + operation.getClass().getSimpleName());
-                System.out.println("threadID : " + threadID + " startTime : " + startTime / 1000 + " consumeTime : " + consumeTime);
             }
             resultReporter.report(0, LdbcNoResult.INSTANCE, operation);
     }