Mercurial > gemma

comparison pkg/imports/wg.go @ 4070:4332b9e26e2f historization_ng

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Merged default
author Sascha Wilde <wilde@intevation.de>
date Thu, 25 Jul 2019 13:20:32 +0200
parents 5fed2f5bc104 fe3dd65c0891
children af2b20d6c921
comparison
equal deleted inserted replaced
4069:12f476e91c70 4070:4332b9e26e2f
20 "time" 20 "time"
21 21
22 "github.com/jackc/pgx/pgtype" 22 "github.com/jackc/pgx/pgtype"
23 23
24 "gemma.intevation.de/gemma/pkg/models" 24 "gemma.intevation.de/gemma/pkg/models"
25 "gemma.intevation.de/gemma/pkg/pgxutils"
25 "gemma.intevation.de/gemma/pkg/soap/erdms" 26 "gemma.intevation.de/gemma/pkg/soap/erdms"
26 ) 27 )
27 28
28 type WaterwayGauge struct { 29 type WaterwayGauge struct {
29 // URL is the URL of the SOAP service. 30 // URL is the URL of the SOAP service.
324 code.String(), 325 code.String(),
325 validity, 326 validity,
326 ).Scan(&isNew) 327 ).Scan(&isNew)
327 switch { 328 switch {
328 case err != nil: 329 case err != nil:
329 feedback.Warn(handleError(err).Error()) 330 feedback.Warn(pgxutils.HandleError(err).Error())
330 if err2 := tx.Rollback(); err2 != nil { 331 if err2 := tx.Rollback(); err2 != nil {
331 return nil, err2 332 return nil, err2
332 } 333 }
333 unchanged++ 334 unchanged++
334 continue 335 continue
349 geodref, 350 geodref,
350 &dateInfo, 351 &dateInfo,
351 source, 352 source,
352 time.Time(*dr.Lastupdate), 353 time.Time(*dr.Lastupdate),
353 ); err != nil { 354 ); err != nil {
354 feedback.Warn(handleError(err).Error()) 355 feedback.Warn(pgxutils.HandleError(err).Error())
355 if err2 := tx.Rollback(); err2 != nil { 356 if err2 := tx.Rollback(); err2 != nil {
356 return nil, err2 357 return nil, err2
357 } 358 }
358 unchanged++ 359 unchanged++
359 continue 360 continue
386 return nil, err3 387 return nil, err3
387 } 388 }
388 unchanged++ 389 unchanged++
389 continue 390 continue
390 case err2 != nil: 391 case err2 != nil:
391 feedback.Warn(handleError(err2).Error()) 392 feedback.Warn(pgxutils.HandleError(err2).Error())
392 if err3 := tx.Rollback(); err3 != nil { 393 if err3 := tx.Rollback(); err3 != nil {
393 return nil, err3 394 return nil, err3
394 } 395 }
395 unchanged++ 396 unchanged++
396 continue 397 continue
433 if _, err = tx.StmtContext(ctx, fixValidityStmt).ExecContext( 434 if _, err = tx.StmtContext(ctx, fixValidityStmt).ExecContext(
434 ctx, 435 ctx,
435 code.String(), 436 code.String(),
436 &validity, 437 &validity,
437 ); err != nil { 438 ); err != nil {
438 feedback.Warn(handleError(err).Error()) 439 feedback.Warn(pgxutils.HandleError(err).Error())
439 if err2 := tx.Rollback(); err2 != nil { 440 if err2 := tx.Rollback(); err2 != nil {
440 return nil, err2 441 return nil, err2
441 } 442 }
442 unchanged++ 443 unchanged++
443 continue 444 continue
481 code.Hectometre, 482 code.Hectometre,
482 &validity, 483 &validity,
483 string(**wl.level), 484 string(**wl.level),
484 int64(**wl.value), 485 int64(**wl.value),
485 ); err != nil { 486 ); err != nil {
486 feedback.Warn(handleError(err).Error()) 487 feedback.Warn(pgxutils.HandleError(err).Error())
487 tx.Rollback() 488 tx.Rollback()
488 continue 489 continue
489 } 490 }
490 } 491 }
491 492