function thread_init()
   drv = sysbench.sql.driver()
end

function prepare()
end

function event()
   con = drv:connect()
   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:disconnect()
end

function thread_done(thread_id)
end

function cleanup()
end