rename bulkInsert function

stellar · Aug 12, 2024 · 877cfb4 · 877cfb4
1 parent 3a60216
commit 877cfb4
Show file tree

Hide file tree

Showing 4 changed files with 10 additions and 10 deletions.
diff --git a/services/horizon/internal/db2/history/account_loader.go b/services/horizon/internal/db2/history/account_loader.go
@@ -106,11 +106,11 @@ func (a *AccountLoader) Exec(ctx context.Context, session db.SessionInterface) e
 	sort.Strings(addresses)
 
 	var accounts []Account
-	err := bulkInsert(
+	err := bulkGetOrCreate(
 		ctx,
 		q,
 		"history_accounts",
-		[]bulkInsertField{
+		[]columnValues{
 			{
 				name:    "address",
 				dbType:  "character varying(64)",
@@ -139,13 +139,13 @@ func (a *AccountLoader) Name() string {
 	return "AccountLoader"
 }
 
-type bulkInsertField struct {
+type columnValues struct {
 	name    string
 	dbType  string
 	objects []string
 }
 
-func bulkInsert(ctx context.Context, q *Q, table string, fields []bulkInsertField, response interface{}) error {
+func bulkGetOrCreate(ctx context.Context, q *Q, table string, fields []columnValues, response interface{}) error {
 	unnestPart := make([]string, 0, len(fields))
 	insertFieldsPart := make([]string, 0, len(fields))
 	pqArrays := make([]interface{}, 0, len(fields))

diff --git a/services/horizon/internal/db2/history/asset_loader.go b/services/horizon/internal/db2/history/asset_loader.go
@@ -128,11 +128,11 @@ func (a *AssetLoader) Exec(ctx context.Context, session db.SessionInterface) err
 	}
 
 	var rows []Asset
-	err := bulkInsert(
+	err := bulkGetOrCreate(
 		ctx,
 		q,
 		"history_assets",
-		[]bulkInsertField{
+		[]columnValues{
 			{
 				name:    "asset_code",
 				dbType:  "character varying(12)",

diff --git a/services/horizon/internal/db2/history/claimable_balance_loader.go b/services/horizon/internal/db2/history/claimable_balance_loader.go
@@ -94,11 +94,11 @@ func (a *ClaimableBalanceLoader) Exec(ctx context.Context, session db.SessionInt
 	// https://github.com/stellar/go/issues/2370
 	sort.Strings(ids)
 	var rows []HistoryClaimableBalance
-	err := bulkInsert(
+	err := bulkGetOrCreate(
 		ctx,
 		q,
 		"history_claimable_balances",
-		[]bulkInsertField{
+		[]columnValues{
 			{
 				name:    "claimable_balance_id",
 				dbType:  "text",

diff --git a/services/horizon/internal/db2/history/liquidity_pool_loader.go b/services/horizon/internal/db2/history/liquidity_pool_loader.go
@@ -94,11 +94,11 @@ func (a *LiquidityPoolLoader) Exec(ctx context.Context, session db.SessionInterf
 	// https://github.com/stellar/go/issues/2370
 	sort.Strings(ids)
 	var rows []HistoryLiquidityPool
-	err := bulkInsert(
+	err := bulkGetOrCreate(
 		ctx,
 		q,
 		"history_liquidity_pools",
-		[]bulkInsertField{
+		[]columnValues{
 			{
 				name:    "liquidity_pool_id",
 				dbType:  "text",