数据库选型之MySQL(二)

 1 DROP TABLE IF EXISTS `transaction`;
 2 CREATE TABLE `transaction` (
 3   `tradedate` datetime DEFAULT NOT NULL,
 4   `symbol` varchar(6) DEFAULT NOT NULL,
 5   `symbolname` varchar(8) DEFAULT NOT NULL,
 6   `trdmintime` varchar(6) DEFAULT NOT NULL,
 7   `startprice` decimal(9,3) DEFAULT NOT NULL,
 8   `highprice` decimal(9,3) DEFAULT NOT NULL,
 9   `lowprice` decimal(9,3) DEFAULT NOT NULL,
10   `endprice` decimal(9,3) DEFAULT NOT NULL,
11   `change` decimal(9,3) DEFAULT NOT NULL,
12   `changeratio` decimal(6,3) DEFAULT NOT NULL,
13   `minvolume` decimal(10,0) DEFAULT NOT NULL,
14   `minamout` decimal(16,3) DEFAULT NOT NULL,
15   `unix` bigint(20) DEFAULT NOT NULL,
16   `market` varchar(3) DEFAULT NOT NULL
17 ) ENGINE=InnoDB DEFAULT CHARSET=utf8;

 1 # read_rnd_buffer_size = 2M
 2 datadir=/var/lib/mysql
 3 socket=/var/lib/mysql/mysql.sock
 4 innodb_flush_log_at_trx_commit = 2
 5 innodb_autoinc_lock_mode = 2
 6 query_cache_type = 1
 7 query_cache_size = 20M
 8 innodb_buffer_pool_size = 2G
 9 innodb_flush_method = O_DSYNC
10 # Disabling symbolic-links is recommended to prevent assorted security risks
11 symbolic-links=0

 1 public void initMySQL()
 2     {
 3         String driver = "com.mysql.jdbc.Driver";
 4         String url = "jdbc:mysql://10.1.120.34:3306/hdfs";
 5         String user = "root";
 6         String password = "";
 7         
 8         try {
 9             Class.forName(driver);
10             conn = DriverManager.getConnection(url, user, password);
11             if (!conn.isClosed())
12                 System.out.println("Start MySQL!");
13         } catch (Exception e) {
14             e.printStackTrace();
15         }
16         
17         count = 0;
18         sql = "insert into transaction" + " values(?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)";
19         try {
20             pstm = conn.prepareStatement(sql);
21             conn.setAutoCommit(false);
22         } catch (SQLException e) {
23             e.printStackTrace();
24         }
25     }

 1 public void insertData(Transaction ts)
 2     {
 3         try {
 4             pstm.setDate(1, ts.getTradedate());
 5             pstm.setString(2,  ts.getSymbol());
 6             pstm.setString(3, ts.getSymbolName());
 7             pstm.setString(4, ts.getTrdmintime());
 8             pstm.setBigDecimal(5, ts.getStartprice());
 9             pstm.setBigDecimal(6, ts.getHighprice());
10             pstm.setBigDecimal(7, ts.getLowprice());
11             pstm.setBigDecimal(8, ts.getEndprice());
12             pstm.setBigDecimal(9, ts.getChange());            
13             pstm.setBigDecimal(10, ts.getChangeratio());
14             pstm.setBigDecimal(11, ts.getMinvolume());
15             pstm.setBigDecimal(12, ts.getMinamout());
16             pstm.setLong(13, ts.getUnix());
17             pstm.setString(14, ts.getMarket());
18     
19             pstm.executeUpdate();
20             count++ ;
21             if (count == Test.PREFIX) {
22                 conn.commit();
23                 conn.setAutoCommit(false);
24                 count = 0;
25             }
26                         
27         } catch (SQLException e) {
28             try {
29                 conn.rollback();
30             } catch (SQLException e1) {
31                 e1.printStackTrace();
32             }
33             e.printStackTrace();
34         }
35     }