Mercurial > gemma

comparison pkg/imports/wg.go @ 5683:31973f6f5cca sr-v2

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Get rid of deprecation warnings from staticcheck.
author Sascha L. Teichmann <sascha.teichmann@intevation.de>
date Sun, 11 Feb 2024 21:37:00 +0100
parents b75d0b303328
children 2dd155cc95ec
comparison
equal deleted inserted replaced
5682:33499bd1b829 5683:31973f6f5cca
178 ) ON CONFLICT (location, validity, depth_reference) DO UPDATE SET 178 ) ON CONFLICT (location, validity, depth_reference) DO UPDATE SET
179 value = EXCLUDED.value 179 value = EXCLUDED.value
180 ` 180 `
181 ) 181 )
182 182
183 var continueErr = errors.New("continue") 183 var errContinue = errors.New("continue")
184 184
185 // Do implements the actual import. 185 // Do implements the actual import.
186 func (wg *WaterwayGauge) Do( 186 func (wg *WaterwayGauge) Do(
187 ctx context.Context, 187 ctx context.Context,
188 importID int64, 188 importID int64,
359 ).Scan(&isNew) 359 ).Scan(&isNew)
360 switch { 360 switch {
361 case err != nil: 361 case err != nil:
362 feedback.Error(pgxutils.ReadableError{Err: err}.Error()) 362 feedback.Error(pgxutils.ReadableError{Err: err}.Error())
363 unchanged++ 363 unchanged++
364 return continueErr 364 return errContinue
365 case isNew: 365 case isNew:
366 var lu *time.Time 366 var lu *time.Time
367 if dr.Lastupdate != nil { 367 if dr.Lastupdate != nil {
368 t := dr.Lastupdate.ToGoTime() 368 t := dr.Lastupdate.ToGoTime()
369 lu = &t 369 lu = &t
386 source, 386 source,
387 lu, 387 lu,
388 ); err != nil { 388 ); err != nil {
389 key := pgxutils.ReadableError{Err: err}.Error() 389 key := pgxutils.ReadableError{Err: err}.Error()
390 databaseErrors[key] = append(databaseErrors[key], isrs) 390 databaseErrors[key] = append(databaseErrors[key], isrs)
391 return continueErr 391 return errContinue
392 } 392 }
393 newGauges = append(newGauges, isrs) 393 newGauges = append(newGauges, isrs)
394 //feedback.Info("insert new version") 394 //feedback.Info("insert new version")
395 case !isNew: 395 case !isNew:
396 var lu *time.Time 396 var lu *time.Time
415 ).Scan(&dummy) 415 ).Scan(&dummy)
416 switch { 416 switch {
417 case err2 == sql.ErrNoRows: 417 case err2 == sql.ErrNoRows:
418 //feedback.Info("unchanged") 418 //feedback.Info("unchanged")
419 unchanged++ 419 unchanged++
420 return continueErr 420 return errContinue
421 case err2 != nil: 421 case err2 != nil:
422 key := pgxutils.ReadableError{Err: err2}.Error() 422 key := pgxutils.ReadableError{Err: err2}.Error()
423 databaseErrors[key] = append(databaseErrors[key], isrs) 423 databaseErrors[key] = append(databaseErrors[key], isrs)
424 unchanged++ 424 unchanged++
425 return continueErr 425 return errContinue
426 default: 426 default:
427 updatedGauges = append(updatedGauges, isrs) 427 updatedGauges = append(updatedGauges, isrs)
428 //feedback.Info("update") 428 //feedback.Info("update")
429 } 429 }
430 430
475 &validity, 475 &validity,
476 ); err != nil { 476 ); err != nil {
477 key := pgxutils.ReadableError{Err: err}.Error() 477 key := pgxutils.ReadableError{Err: err}.Error()
478 databaseErrors[key] = append(databaseErrors[key], isrs) 478 databaseErrors[key] = append(databaseErrors[key], isrs)
479 unchanged++ 479 unchanged++
480 return continueErr 480 return errContinue
481 } 481 }
482 482
483 // "Upsert" reference water levels 483 // "Upsert" reference water levels
484 for _, wl := range []struct { 484 for _, wl := range []struct {
485 level **erdms.RisreflevelcodeType 485 level **erdms.RisreflevelcodeType
527 } 527 }
528 528
529 return tx.Commit() 529 return tx.Commit()
530 }() 530 }()
531 531
532 if err != nil && err != continueErr { 532 if err != nil && err != errContinue {
533 return err, nil 533 return err, nil
534 } 534 }
535 } 535 }
536 } 536 }
537 537