|
|
@@ -53,7 +53,7 @@ func ImportDir(datapath string, parallel int, rebuild, reload bool) (totalfilesc
|
|
|
}
|
|
|
|
|
|
func (importer *Importer) Import() (totalfilescount, totallinecount, totalrecordscount, totalretrycount int64, totalusetime time.Duration, filescount, linescount, recordscount, retrycount int64, usetime time.Duration, err error) {
|
|
|
- if odbc.DevPhase&odbc.DP_PROCESSCONTINUE != 0 && !importer.reload {
|
|
|
+ if odbc.DevPhase&odbc.DP_PROCESSCONTINUE != 0 && !importer.reload && !importer.rebuild {
|
|
|
// reload
|
|
|
err = importer.importstatus.Load()
|
|
|
if err != nil {
|
|
|
@@ -352,7 +352,7 @@ func (importer *Importer) importRecord(record map[string]any, line string, filen
|
|
|
if e != nil {
|
|
|
return 0, merrs.NewError(e)
|
|
|
}
|
|
|
- logger.Debug(fmt.Sprint("import ", filename, "[", linecount, "]:", string(bs)))
|
|
|
+ logger.Trace(fmt.Sprint("import ", filename, "[", linecount, "]:", string(bs)))
|
|
|
}
|
|
|
var classaliasname string
|
|
|
switch filetype {
|
