Merge pull request #68 from databendcloud/fix/extract-row

fix: extract row number

Author: hantmac

source/mysql.go

@@ -264,7 +264,7 @@ func (s *MysqlSource) QueryTableData(threadNum int, conditionSql string) ([][]in
 	}
 	s.statsRecorder.RecordMetric(len(result))
 	stats := s.statsRecorder.Stats(time.Since(startTime))
-	log.Printf("thread-%d: extract %d rows (%f rows/s)", threadNum, len(result), stats.RowsPerSecondd)
+	log.Printf("thread-%d: extract %d rows (%f rows/s)", threadNum, len(result)+1, stats.RowsPerSecondd)
 
 	return result, columns, nil
 }
@@ -283,7 +283,6 @@ func (s *MysqlSource) GetDatabasesAccordingToSourceDbRegex(sourceDatabasePattern
 		if err != nil {
 			return nil, err
 		}
-		fmt.Println("sourcedatabase pattern", sourceDatabasePattern)
 		match, err := regexp.MatchString(sourceDatabasePattern, database)
 		if err != nil {
 			return nil, err

source/oracle.go

@@ -288,7 +288,7 @@ func (p *OracleSource) QueryTableData(threadNum int, conditionSql string) ([][]i
 	}
 	p.statsRecorder.RecordMetric(len(result))
 	stats := p.statsRecorder.Stats(time.Since(startTime))
-	log.Printf("thread-%d: extract %d rows (%f rows/s)", threadNum, len(result), stats.RowsPerSecondd)
+	log.Printf("thread-%d: extract %d rows (%f rows/s)", threadNum, len(result)+1, stats.RowsPerSecondd)
 
 	return result, columns, nil
 }

source/postgres.go

@@ -285,7 +285,7 @@ func (p *PostgresSource) QueryTableData(threadNum int, conditionSql string) ([][
 	}
 	p.statsRecorder.RecordMetric(len(result))
 	stats := p.statsRecorder.Stats(time.Since(startTime))
-	log.Printf("thread-%d: extract %d rows (%f rows/s)", threadNum, len(result), stats.RowsPerSecondd)
+	log.Printf("thread-%d: extract %d rows (%f rows/s)", threadNum, len(result)+1, stats.RowsPerSecondd)
 
 	return result, columns, nil
 }

source/sql_server.go

@@ -409,7 +409,6 @@ func (s *SQLServerSource) GetDatabasesAccordingToSourceDbRegex(sourceDatabasePat
 			return nil, fmt.Errorf("scanning database name: %w", err)
 		}
 
-		fmt.Println("sourcedatabase pattern:", sourceDatabasePattern)
 		match, err := regexp.MatchString(sourceDatabasePattern, database)
 		if err != nil {
 			return nil, fmt.Errorf("matching pattern: %w", err)