Shulou(Shulou.com)06/01 Report--

Benchmarksql4.0 has been used before to do a test, National Day with Benchmarksql5.0 also tried, BM5.0 and 4.1 is different in that he set the database type. If there is no corresponding database type, it will be reported that the index is not supported. Java package and SH script need to be modified to add a DM type.

I. Prepare the environment

1. A DM database has been started

2. Java 1.7 and above

3. 下载解压BMSQL5.0

4. 将DMJDBC-1.8 放到bmsqsl 的lib 下

二、BMSQL 脚本新修改

1. 复制一个props.ora 该名为props.dm 并修改内容

# cp props.ora props.dm

# vi props.dm

db=dm

driver=dm.jdbc.driver.DmDriver

conn=jdbc:dm://LOCALHOST:5236

user=BMSQL

password=123456789

2. 进入/opt/benchmarksql-5.0/run/sql.common 修改tableCreate.sql

create table benchmarksql.bmsql_config (

cfg_name varchar(30) primary key,

cfg_value varchar(50)

);

create table benchmarksql.bmsql_warehouse (

w_id int not null,

w_ytd float,

w_tax float,

w_name varchar(10),

w_street_1 varchar(20),

w_street_2 varchar(20),

w_city varchar(20),

w_state char(2),

w_zip char(9),

cluster primary key(w_id)

)storage(fillfactor 2,without counter);

create table benchmarksql.bmsql_district (

d_w_id int not null,

d_id int not null,

d_ytd float,

d_tax float,

d_next_o_id int,

d_name varchar(10),

d_street_1 varchar(20),

d_street_2 varchar(20),

d_city varchar(20),

d_state char(2),

d_zip char(9),

cluster primary key(d_w_id,d_id)

)storage(fillfactor 2,without counter);

create table benchmarksql.bmsql_customer (

c_w_id int not null,

c_d_id int not null,

c_id int not null,

c_discount float,

c_credit char(2),

c_last varchar(16),

c_first varchar(16),

c_credit_lim float,

c_balance float,

c_ytd_payment float,

c_payment_cnt int,

c_delivery_cnt int,

c_street_1 varchar(20),

c_street_2 varchar(20),

c_city varchar(20),

c_state char(2),

c_zip char(9),

c_phone char(16),

c_since timestamp,

c_middle char(2),

c_data varchar(500),

cluster primary key(c_w_id,c_d_id,c_id)

);

create sequence benchmarksql.bmsql_hist_id_seq;

create table benchmarksql.bmsql_history (

hist_id int default benchmarksql.bmsql_hist_id_seq.NEXTVAL,

h_c_id int,

h_c_d_id int,

h_c_w_id int,

h_d_id int,

h_w_id int,

h_date timestamp,

h_amount float,

h_data varchar(24)

)storage(branch(32,32),without counter);

create table benchmarksql.bmsql_oorder (

o_w_id int not null,

o_d_id int not null,

o_id int not null,

o_c_id int,

o_carrier_id int,

o_ol_cnt float,

o_all_local float,

o_entry_d timestamp,

cluster primary key(o_w_id,o_d_id,o_id)

);

create table benchmarksql.bmsql_new_order (

no_w_id int not null,

no_d_id int not null,

no_o_id int not null,

cluster primary key(no_w_id,no_d_id,no_o_id)

);

create table benchmarksql.bmsql_order_line (

ol_w_id int not null,

ol_d_id int not null,

ol_o_id int not null,

ol_number int not null,

ol_i_id int not null,

ol_delivery_d timestamp,

ol_amount float,

ol_supply_w_id int,

ol_quantity float,

ol_dist_info char(24),

cluster primary key(ol_w_id,ol_d_id,ol_o_id,ol_number)

);

create table benchmarksql.bmsql_stock (

s_w_id int not null,

s_i_id int not null,

s_quantity float,

s_ytd float,

s_order_cnt int,

s_remote_cnt int,

s_data varchar(50),

s_dist_01 char(24),

s_dist_02 char(24),

s_dist_03 char(24),

s_dist_04 char(24),

s_dist_05 char(24),

s_dist_06 char(24),

s_dist_07 char(24),

s_dist_08 char(24),

s_dist_09 char(24),

s_dist_10 char(24),

cluster primary key(s_i_id,s_w_id)

);

create table benchmarksql.bmsql_item (

i_id int not null,

i_name varchar(24),

i_price float,

i_data varchar(50),

i_im_id int,

cluster primary key(i_id)

);

注1 ：DECIMAL 类型都改为FLOAT 类型

注2 ：去掉外键

注3 ：主键强制聚集

修改indexCreate.sql 脚本

create index ndx_customer_name

on benchmarksql.customer (c_w_id, c_d_id, c_last, c_first);

目前只需要这一个索引

三、 修改JAVA 包和sh 脚本添加DM7

# cd /opt/benchmarksql-5.0/src/client/jTPCC.java

# vi jTPCC.java

if (iDB.equals("firebird"))

dbType = DB_FIREBIRD;

else if (iDB.equals("oracle"))

dbType = DB_ORACLE;

else if (iDB.equals("postgres"))

dbType = DB_POSTGRES;

else if (iDB.equals("dm7"))

dbType = DB_DM;

else

{

log.error("unknown database type '" + iDB + "'");

return;

}

if(Integer.parseInt(limPerMin) !=0){

limPerMin_Terminal = Integer.parseInt(limPerMin)/Integer.parseInt(iTerminals);

}

else{

limPerMin_Terminal = -1;

}

标红处为手动添加的数据库类型

#cd /opt/benchmarksql-5.0/run

#vi funcs.sh

function setCP()

{

case "$(getProp db)" in

firebird)

cp="../lib/firebird/*:../lib/*"

;;

oracle)

cp="../lib/oracle/*"

if [ ! -z "${ORACLE_HOME}" -a -d ${ORACLE_HOME}/lib ] ; then

cp="${cp}:${ORACLE_HOME}/lib/*"

fi

cp="${cp}:../lib/*"

;;

postgres)

cp="../lib/postgres/*:../lib/*"

;;

dm7)

cp="../lib/dm7/*:../lib/*"

;;

esac

myCP=".:${cp}:../dist/*"

export myCP

}

省略。。。。。。。。。。。

case "$(getProp db)" in

firebird|oracle|postgres| dm7)

;;

"") echo "ERROR: missing db= config option in ${PROPS}" >&2

exit 1

;;

*) echo "ERROR: unsupported database type 'db=$(getProp db)' in ${PROPS}" >&2

exit 1

;;

esac

标红处为添加部分

四、 执行数据创建和装载

1. 创建表和索引

#./runSql props.dm sql.common/tableCreate.sql

#./runSql props.dm sql.common/indexCreate.sql

2. 装载数据

#./runLoader.sh props.dm warehourse 1

五、 运行TPC-C

./runBenchmark.sh props.dm

执行结束

Welcome to subscribe "Shulou Technology Information " to get latest news, interesting things and hot topics in the IT industry, and controls the hottest and latest Internet news, technology news and IT industry trends.