main.go

   1 package main
   2
   3 import (
   4         "database/sql"
   5         "fmt"
   6
   7         _ "github.com/go-sql-driver/mysql"
   8         "github.com/jinzhu/gorm"
   9
  10         "github.com/vapor/federation/common"
  11         // "github.com/vapor/federation/config"
  12         "github.com/vapor/federation/database/orm"
  13 )
  14
  15 func main() {
  16         dsnTemplate := "%s:%s@tcp(%s:%d)/%s?charset=utf8&parseTime=true&loc=Local"
  17         dsn := fmt.Sprintf(dsnTemplate, "root", "toor", "127.0.0.1", 3306, "federation")
  18         db, err := gorm.Open("mysql", dsn)
  19         if err != nil {
  20                 panic(err)
  21         }
  22
  23         db.LogMode(true)
  24         // UPDATE `cross_transactions` SET `dest_block_hash` = 'blockHash.String()', `dest_block_height` = '2', `dest_tx_index` = '3', `status` = '3'  WHERE (`cross_transactions`.`chain_id` = '1') AND (`cross_transactions`.`dest_tx_hash` = 'tx.ID.String()') AND (`cross_transactions`.`status` = '2')
  25         if err := db.Model(&orm.CrossTransaction{}).Where("chain_id != ?", 1).
  26                 Where(&orm.CrossTransaction{
  27                         DestTxHash: sql.NullString{"tx.ID.String()", true},
  28                         Status:     common.CrossTxSubmittedStatus,
  29                 }).UpdateColumn(&orm.CrossTransaction{
  30                 DestBlockHeight: sql.NullInt64{int64(2), true},
  31                 DestBlockHash:   sql.NullString{"blockHash.String()", true},
  32                 DestTxIndex:     sql.NullInt64{int64(3), true},
  33                 Status:          common.CrossTxCompletedStatus,
  34         }).Error; err != nil {
  35                 panic(err)
  36         }
  37 }