Skip to content

Commit b5acd31

Browse files
committed
remove DuckDB::Appender#begin_row
- remove from tests - remove from documents
1 parent f62d845 commit b5acd31

File tree

5 files changed

+6
-24
lines changed

5 files changed

+6
-24
lines changed

README.md

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -218,7 +218,6 @@ def append
218218
appender = con.appender('users')
219219
220220
10000.times do
221-
appender.begin_row
222221
appender.append(1)
223222
appender.append('Alice')
224223
appender.end_row

ext/duckdb/appender.c

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -117,7 +117,6 @@ static VALUE appender_error_message(VALUE self) {
117117
* con.query('CREATE TABLE users (id INTEGER, name VARCHAR)')
118118
* appender = con.appender('users')
119119
* appender
120-
* .begin_row
121120
* .append_int32(1)
122121
* .append_varchar('Alice')
123122
* .end_row
@@ -144,7 +143,6 @@ static VALUE appender_end_row(VALUE self) {
144143
* con.query('CREATE TABLE users (id INTEGER, active BOOLEAN)')
145144
* appender = con.appender('users')
146145
* appender
147-
* .begin_row
148146
* .append_int32(1)
149147
* .append_bool(true)
150148
* .end_row
@@ -175,7 +173,6 @@ static VALUE appender_append_bool(VALUE self, VALUE val) {
175173
* con.query('CREATE TABLE users (id INTEGER, age TINYINT)')
176174
* appender = con.appender('users')
177175
* appender
178-
* .begin_row
179176
* .append_int32(1)
180177
* .append_int8(20)
181178
* .end_row
@@ -204,7 +201,6 @@ static VALUE appender_append_int8(VALUE self, VALUE val) {
204201
* con.query('CREATE TABLE users (id INTEGER, age SMALLINT)')
205202
* appender = con.appender('users')
206203
* appender
207-
* .begin_row
208204
* .append_int32(1)
209205
* .append_int16(20)
210206
* .end_row
@@ -233,7 +229,6 @@ static VALUE appender_append_int16(VALUE self, VALUE val) {
233229
* con.query('CREATE TABLE users (id INTEGER, age INTEGER)')
234230
* appender = con.appender('users')
235231
* appender
236-
* .begin_row
237232
* .append_int32(1)
238233
* .append_int32(20)
239234
* .end_row
@@ -262,7 +257,6 @@ static VALUE appender_append_int32(VALUE self, VALUE val) {
262257
* con.query('CREATE TABLE users (id INTEGER, age BIGINT)')
263258
* appender = con.appender('users')
264259
* appender
265-
* .begin_row
266260
* .append_int32(1)
267261
* .append_int64(20)
268262
* .end_row

lib/duckdb/appender.rb

Lines changed: 1 addition & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -44,7 +44,6 @@ def begin_row
4444
# con.query('CREATE TABLE users (id INTEGER, name VARCHAR)')
4545
# appender = con.appender('users')
4646
# appender
47-
# .begin_row
4847
# .append_int32(1)
4948
# .append_varchar('Alice')
5049
# .end_row
@@ -63,7 +62,6 @@ def flush
6362
# con.query('CREATE TABLE numbers (num HUGEINT)')
6463
# appender = con.appender('numbers')
6564
# appender
66-
# .begin_row
6765
# .append_hugeint(-170_141_183_460_469_231_731_687_303_715_884_105_727)
6866
# .end_row
6967
def append_hugeint(value)
@@ -79,7 +77,6 @@ def append_hugeint(value)
7977
# con.query('CREATE TABLE numbers (num UHUGEINT)')
8078
# appender = con.appender('numbers')
8179
# appender
82-
# .begin_row
8380
# .append_hugeint(340_282_366_920_938_463_463_374_607_431_768_211_455)
8481
# .end_row
8582
def append_uhugeint(value)
@@ -94,7 +91,6 @@ def append_uhugeint(value)
9491
# con = db.connect
9592
# con.query('CREATE TABLE dates (date_value DATE)')
9693
# appender = con.appender('dates')
97-
# appender.begin_row
9894
# appender.append_date(Date.today)
9995
# # or
10096
# # appender.append_date(Time.now)
@@ -114,7 +110,6 @@ def append_date(value)
114110
# con = db.connect
115111
# con.query('CREATE TABLE times (time_value TIME)')
116112
# appender = con.appender('times')
117-
# appender.begin_row
118113
# appender.append_time(Time.now)
119114
# # or
120115
# # appender.append_time('01:01:01')
@@ -133,7 +128,6 @@ def append_time(value)
133128
# con = db.connect
134129
# con.query('CREATE TABLE timestamps (timestamp_value TIMESTAMP)')
135130
# appender = con.appender('timestamps')
136-
# appender.begin_row
137131
# appender.append_time(Time.now)
138132
# # or
139133
# # appender.append_time(Date.today)
@@ -156,7 +150,6 @@ def append_timestamp(value)
156150
# con.query('CREATE TABLE intervals (interval_value INTERVAL)')
157151
# appender = con.appender('intervals')
158152
# appender
159-
# .begin_row
160153
# .append_interval('P1Y2D') # => append 1 year 2 days interval.
161154
# .end_row
162155
# .flush
@@ -172,7 +165,6 @@ def append_interval(value)
172165
# con = db.connect
173166
# con.query('CREATE TABLE users (id INTEGER, name VARCHAR)')
174167
# appender = con.appender('users')
175-
# appender.begin_row
176168
# appender.append(1)
177169
# appender.append('Alice')
178170
# appender.end_row
@@ -214,12 +206,10 @@ def append(value)
214206
#
215207
# is same as:
216208
#
217-
# appender.begin_row
218-
# appender.append(1)
209+
# appender.append(2)
219210
# appender.append('Alice')
220211
# appender.end_row
221212
def append_row(*args)
222-
begin_row
223213
args.each do |arg|
224214
append(arg)
225215
end

lib/duckdb/interval.rb

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,6 @@ module DuckDB
2424
# con.query('CREATE TABLE intervals (interval_value INTERVAL)')
2525
# appender = con.appender('intervals')
2626
# appender
27-
# .begin_row
2827
# .append_interval(interval)
2928
# .end_row
3029
# .flush

test/duckdb_test/appender_test.rb

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -51,7 +51,6 @@ def test_s_new_with_schema
5151

5252
def sub_test_append_column2(method, type, values:, expected:)
5353
create_appender("col #{type}")
54-
@appender.begin_row
5554
@appender.send(method, *values)
5655
@appender.end_row
5756
@appender.flush
@@ -72,8 +71,6 @@ def sub_assert_equal(expected, actual)
7271
def assert_duckdb_appender(expected, type, &block)
7372
create_appender("col #{type}")
7473

75-
@appender.begin_row
76-
7774
block.call(@appender) if block_given?
7875

7976
@appender.end_row
@@ -88,10 +85,14 @@ def assert_duckdb_appender(expected, type, &block)
8885
teardown
8986
end
9087

88+
def test_begin_row
89+
appender = create_appender('col BOOLEAN')
90+
assert_equal(appender.__id__, appender.begin_row.__id__)
91+
end
92+
9193
def test_flush
9294
appender = create_appender('col BOOLEAN')
9395
appender
94-
.begin_row
9596
.append_bool(true)
9697
.end_row
9798
assert_equal(appender.__id__, appender.flush.__id__)
@@ -100,7 +101,6 @@ def test_flush
100101
def test_flush_with_exception
101102
appender = create_appender('col BOOLEAN NOT NULL')
102103
appender
103-
.begin_row
104104
.append_null
105105
.end_row
106106
exception = assert_raises(DuckDB::Error) { appender.flush }

0 commit comments

Comments
 (0)