class Object
Public Instance Methods
Source
# File sample/issue922_benchmark.rb, line 120 def query_via_parquet(con, data_frame, name, parquet_path) data_frame.write_parquet(parquet_path) con.query("CREATE OR REPLACE TABLE #{name} AS SELECT * FROM read_parquet('#{parquet_path}')") con.query("SELECT * FROM #{name}").to_a end
Source
# File sample/issue930_benchmark.rb, line 35 def register_as_table_with_create_table(con, csv, name) headers = csv.first.headers csv.rewind con.execute("CREATE OR REPLACE TABLE #{name} (#{headers.map { |h| "#{h} VARCHAR" }.join(', ')})") csv.each do |row| values = row.map { |cell| "'#{cell[1]}'" }.join(', ') con.execute("INSERT INTO #{name} VALUES (#{values})") end end