Skip to content

Commit d36c3e8

Browse files
committed
replace deprecated calls
1 parent d12ce37 commit d36c3e8

File tree

4 files changed

+13
-13
lines changed

4 files changed

+13
-13
lines changed

batch_test.go

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -93,10 +93,10 @@ func TestBatch_WithNowInSeconds(t *testing.T) {
9393
t.Fatal(err)
9494
}
9595

96-
b := session.NewBatch(LoggedBatch)
96+
b := session.Batch(LoggedBatch)
9797
b.WithNowInSeconds(0)
9898
b.Query("INSERT INTO batch_now_in_seconds (id, val) VALUES (?, ?) USING TTL 20", 1, "val")
99-
if err := session.ExecuteBatch(b); err != nil {
99+
if err := b.Exec(); err != nil {
100100
t.Fatal(err)
101101
}
102102

@@ -140,10 +140,10 @@ func TestBatch_SetKeyspace(t *testing.T) {
140140
ids := []int{1, 2}
141141
texts := []string{"val1", "val2"}
142142

143-
b := session.NewBatch(LoggedBatch).SetKeyspace("gocql_keyspace_override_test")
143+
b := session.Batch(LoggedBatch).SetKeyspace("gocql_keyspace_override_test")
144144
b.Query("INSERT INTO batch_keyspace(id, value) VALUES (?, ?)", ids[0], texts[0])
145145
b.Query("INSERT INTO batch_keyspace(id, value) VALUES (?, ?)", ids[1], texts[1])
146-
err = session.ExecuteBatch(b)
146+
err = b.Exec()
147147
if err != nil {
148148
t.Fatal(err)
149149
}

cassandra_test.go

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -3899,15 +3899,15 @@ func TestStmtCacheUsesOverriddenKeyspace(t *testing.T) {
38993899

39003900
// Inserting data via Batch to ensure that batches
39013901
// properly accounts for keyspace overriding
3902-
b1 := session.NewBatch(LoggedBatch)
3902+
b1 := session.Batch(LoggedBatch)
39033903
b1.Query(insertQuery, 1)
3904-
err = session.ExecuteBatch(b1)
3904+
err = b1.Exec()
39053905
require.NoError(t, err)
39063906

3907-
b2 := session.NewBatch(LoggedBatch)
3907+
b2 := session.Batch(LoggedBatch)
39083908
b2.SetKeyspace("gocql_test_stmt_cache")
39093909
b2.Query(insertQuery, 2)
3910-
err = session.ExecuteBatch(b2)
3910+
err = b2.Exec()
39113911
require.NoError(t, err)
39123912

39133913
var scannedID int

example_lwt_batch_test.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -32,8 +32,8 @@ import (
3232
gocql "github.com/apache/cassandra-gocql-driver/v2"
3333
)
3434

35-
// ExampleSession_MapExecuteBatchCAS demonstrates how to execute a batch lightweight transaction.
36-
func ExampleSession_MapExecuteBatchCAS() {
35+
// ExampleBatch_MapExecCAS demonstrates how to execute a batch lightweight transaction.
36+
func ExampleBatch_MapExecCAS() {
3737
/* The example assumes the following CQL was used to setup the keyspace:
3838
create keyspace example with replication = { 'class' : 'SimpleStrategy', 'replication_factor' : 1 };
3939
create table example.my_lwt_batch_table(pk text, ck text, version int, value text, PRIMARY KEY(pk, ck));
@@ -72,7 +72,7 @@ func ExampleSession_MapExecuteBatchCAS() {
7272
Args: []interface{}{"B", "pk1", "ck2", ck2Version},
7373
})
7474
m := make(map[string]interface{})
75-
applied, iter, err := b.WithContext(ctx).MapExecCAS(m)
75+
applied, iter, err := b.MapExecCAS(m)
7676
if err != nil {
7777
log.Fatal(err)
7878
}

session_test.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -78,7 +78,7 @@ func TestSessionAPI(t *testing.T) {
7878
err := testBatch.Exec()
7979

8080
if err != ErrNoConnections {
81-
t.Fatalf("expected session.ExecuteBatch to return '%v', got '%v'", ErrNoConnections, err)
81+
t.Fatalf("expected batch.Exec to return '%v', got '%v'", ErrNoConnections, err)
8282
}
8383

8484
s.Close()
@@ -90,7 +90,7 @@ func TestSessionAPI(t *testing.T) {
9090

9191
err = testBatch.Exec()
9292
if err != ErrSessionClosed {
93-
t.Fatalf("expected session.ExecuteBatch to return '%v', got '%v'", ErrSessionClosed, err)
93+
t.Fatalf("expected batch.Exec to return '%v', got '%v'", ErrSessionClosed, err)
9494
}
9595
}
9696

0 commit comments

Comments
 (0)