#!/usr/bin/env sysbench
-- -------------------------------------------------------------------------- --
-- Bulk insert benchmark: do multi-row INSERTs concurrently in --threads
-- threads with each thread inserting into its own table. The number of INSERTs
-- executed by each thread is controlled by either --time or --events.
-- -------------------------------------------------------------------------- --

cursize=0

function thread_init()
   drv = sysbench.sql.driver()
   con = drv:connect()
end

function prepare()
   local i

   local drv = sysbench.sql.driver()
   local con = drv:connect()
end

function event()
   local r = sb_rand(1, 65535)
   con:query(string.format([[
	CREATE TEMPORARY TABLE IF NOT EXISTS sbtest_tmp_%d_%d (
	  id INTEGER NOT NULL,
          KEY (id)) ENGINE=MEMORY]], thread_id, r))
   con:query("LOAD DATA INFILE '/tmp/rickf.csv' INTO TABLE sbtest_tmp_" .. thread_id .. "_" .. r .. " FIELDS TERMINATED BY ','  LINES TERMINATED BY '\n'")
-- con:query("DROP TABLE sbtest_tmp_" .. thread_id .. "_" .. r)
end

function thread_done(thread_id)
   con:disconnect()
end

function cleanup()
   local i

   local drv = sysbench.sql.driver()
   local con = drv:connect()

end