org.apache.derbyTesting.system.oe.load

Class SimpleInsert

java.lang.Object

org.apache.derbyTesting.system.oe.load.SimpleInsert

All Implemented Interfaces:

Load

Direct Known Subclasses:

ThreadInsert

public class SimpleInsert
extends java.lang.Object
implements Load

Implement the initial database population according to the TPC-C database population requirements in Clause 4.3 using simple Insert sql statements

Field Summary

Fields

Modifier and Type	Field and Description
(package private) java.sql.Connection	conn database connection
(package private) OERandom	random Utility to generate random data per the TPC-C requirements
(package private) short	scale warehouse scale factor, default to 1.
(package private) long	seed Seed value for random number generator.

Fields inherited from interface org.apache.derbyTesting.system.oe.client.Load

CUSTOMER_COUNT_W, DISTRICT_COUNT_W, HISTORY_COUNT_W, ITEM_COUNT, NEWORDERS_BREAKPOINT, NEWORDERS_COUNT_W, ORDERLINE_COUNT_WV, ORDERS_COUNT_W, STOCK_COUNT_W

Constructor Summary

Constructors

Constructor and Description
SimpleInsert()

Method Summary

Modifier and Type	Method and Description
void	customerTable(short w, short d) Populate the CUSTOMER table for a given district for a specific warehouse.
void	districtTable(short w, short d) Populate the DISTRICT table for a given warehouse.
void	itemTable(int itemStart, int itemEnd) Populate the ITEM table.
void	orderTable(short w, short d) Populate the ORDER table See population requirements in section 4.3.3.1
void	populateAllTables() Follow the initial database population requirements in Section 4.3.3 and populate all the required tables.
(package private) void	populateForOneWarehouse(short w) Populate all the tables needed for a specific warehouse.
(package private) void	setRandomGenerator() Setup the random number generator to be used for the load.
void	setSeed(long seed) Set the seed for the random number generator used to populate the data.
void	setThreadCount(int threadCount) Ignore, this is a single threaded load.
(package private) void	setupConnection(java.sql.Connection conn, short scale) Set the connection up to the intended state.
void	setupLoad(java.sql.Connection conn, short scale) Perform the necessary setup before database population.
void	stockTable(int itemStart, int itemEnd, short w) Populate the STOCK table for a given warehouse.
void	warehouseTable(short w) Populate the WAREHOUSE table for a given warehouse.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

conn

java.sql.Connection conn

database connection

scale

short scale

warehouse scale factor, default to 1.

seed

long seed

Seed value for random number generator.

random

OERandom random

Utility to generate random data per the TPC-C requirements

Constructor Detail

SimpleInsert

public SimpleInsert()

Method Detail

setupLoad

public void setupLoad(java.sql.Connection conn,
                      short scale)
               throws java.sql.SQLException

Perform the necessary setup before database population.

Specified by:

setupLoad in interface Load

Parameters:

conn - - database connection

scale - - scale of the database. The WAREHOUSE table is used as the base unit of scaling.

Throws:

java.lang.Exception

java.sql.SQLException

setupConnection

void setupConnection(java.sql.Connection conn,
                     short scale)
              throws java.sql.SQLException

Set the connection up to the intended state. Intended for use by sub-classes.

Throws:

java.sql.SQLException

setRandomGenerator

void setRandomGenerator()
                 throws java.sql.SQLException

Setup the random number generator to be used for the load.

Throws:

java.sql.SQLException

populateAllTables

public void populateAllTables()
                       throws java.lang.Exception

Follow the initial database population requirements in Section 4.3.3 and populate all the required tables.

Specified by:

populateAllTables in interface Load

Throws:

java.sql.SQLException

java.lang.Exception

populateForOneWarehouse

void populateForOneWarehouse(short w)
                      throws java.sql.SQLException

Populate all the tables needed for a specific warehouse. for each row in warehouse table, load the stock, district table. For each row in district table, load the customer table. for each row in customer table, load the customer table. for each row in customer table, load

Parameters:

w - Warehouse to be populated.

Throws:

java.sql.SQLException

itemTable

public void itemTable(int itemStart,
                      int itemEnd)
               throws java.sql.SQLException

Populate the ITEM table. See population requirements in section 4.3.3.1

Parameters:

itemStart - insert item information starting from this Item id (ITEM.I_ID)

itemEnd - last Item id (ITEM.I_ID) for inserting information for

Throws:

java.sql.SQLException

warehouseTable

public void warehouseTable(short w)
                    throws java.sql.SQLException

Populate the WAREHOUSE table for a given warehouse. See population requirements in section 4.3.3.1

Parameters:

w - WAREHOUSE ID (W_ID) to insert data for.

Throws:

java.sql.SQLException

stockTable

public void stockTable(int itemStart,
                       int itemEnd,
                       short w)
                throws java.sql.SQLException

Populate the STOCK table for a given warehouse. See population requirements in section 4.3.3.1

Parameters:

itemStart - insert stocks of items from this Item id (ITEM.I_ID)

itemEnd - last Item id (ITEM.I_ID) to insert stocks of times for.

w - WAREHOUSE id (W_ID) for which the stock is populated.

Throws:

java.sql.SQLException

districtTable

public void districtTable(short w,
                          short d)
                   throws java.sql.SQLException

Populate the DISTRICT table for a given warehouse. See population requirements in section 4.3.3.1

Parameters:

w - - WAREHOUSE id (W_ID)

d - - DISTRICT id (D_ID)

Throws:

java.sql.SQLException

customerTable

public void customerTable(short w,
                          short d)
                   throws java.sql.SQLException

Populate the CUSTOMER table for a given district for a specific warehouse. See population requirements in section 4.3.3.1

Parameters:

w - - WAREHOUSE id (W_ID)

d - - DISTRICT id (D_ID)

Throws:

java.sql.SQLException

orderTable

public void orderTable(short w,
                       short d)
                throws java.sql.SQLException

Populate the ORDER table See population requirements in section 4.3.3.1

Parameters:

w - - WAREHOUSE id (W_ID)

d - - DISTRICT id (D_ID)

Throws:

java.sql.SQLException

setSeed

public void setSeed(long seed)

Description copied from interface: Load

Set the seed for the random number generator used to populate the data. Useful for testing to ensure consistent repeatable runs. If not set, defaults a value based upon current time. Must be called before setupLoad to have an effect.

Specified by:

setSeed in interface Load

setThreadCount

public void setThreadCount(int threadCount)

Ignore, this is a single threaded load.

Specified by:

setThreadCount in interface Load

Parameters:

threadCount - Number of threads to use if loading supports multiple threading.