Skip to content

Commit 6e22be2

Browse files
committed
Update exec_query references to internal_exec_query to handle connection
1 parent 291162a commit 6e22be2

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

lib/arjdbc/sqlite3/adapter.rb

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -261,7 +261,7 @@ def remove_index(table_name, column_name = nil, **options) # :nodoc:
261261

262262
index_name = index_name_for_remove(table_name, column_name, options)
263263

264-
exec_query "DROP INDEX #{quote_column_name(index_name)}"
264+
internal_exec_query "DROP INDEX #{quote_column_name(index_name)}"
265265
end
266266

267267

@@ -272,7 +272,7 @@ def remove_index(table_name, column_name = nil, **options) # :nodoc:
272272
def rename_table(table_name, new_name)
273273
schema_cache.clear_data_source_cache!(table_name.to_s)
274274
schema_cache.clear_data_source_cache!(new_name.to_s)
275-
exec_query "ALTER TABLE #{quote_table_name(table_name)} RENAME TO #{quote_table_name(new_name)}"
275+
internal_exec_query "ALTER TABLE #{quote_table_name(table_name)} RENAME TO #{quote_table_name(new_name)}"
276276
rename_table_indexes(table_name, new_name)
277277
end
278278

@@ -432,7 +432,7 @@ def bind_params_length
432432
end
433433

434434
def table_structure(table_name)
435-
structure = exec_query("PRAGMA table_info(#{quote_table_name(table_name)})", "SCHEMA")
435+
structure = internal_exec_query("PRAGMA table_info(#{quote_table_name(table_name)})", "SCHEMA")
436436
raise(ActiveRecord::StatementInvalid, "Could not find table '#{table_name}'") if structure.empty?
437437
table_structure_with_collation(table_name, structure)
438438
end

0 commit comments

Comments
 (0)