文件采集到mysql_java 每日习题（六）从文件收集数据记录到mysql

左手的ㄟ右手 2022-10-27 13:43 80阅读 0赞

1. mysql建库，建表

2. 准备数据文件cpu.txt

1447836374319,169,0,0

1447836375346,498,0,0

1447836376346,250,0,0

1447836377347,0,0,0

1447836378347,497,0,0

1447836379347,0,0,0

1447836380347,498,0,0

1447836381348,0,0,0

1447836382348,498,0,0

1447836383348,0,0,0

1447836384348,248,0,0

1447836385348,0,0,0

3. 收集数据记录到mysql

使用到的类说明：

3.1  File 获取文件句柄，File实例代表一个本地文件。

3.2  FileInputStream is meant for reading streams of raw bytes such as image data.

3.3  An InputStreamReader is a bridge from byte streams to character streams: It reads bytes and decodes them into characters using a specified charset.

3.4  BufferedReader: Reads text from a character-input stream, buffering characters so as to provide for the efficient reading of characters, arrays, and lines.

packagecollect\_part;importjava.io.BufferedReader;importjava.io.File;importjava.io.FileInputStream;importjava.io.InputStreamReader;public classCollectData \{public static voidmain(String\[\] args) \{

String path= "d:\\\\logs\\\\cpu.txt";

CollectData data= newCollectData();

data.readFile(path);

\}public voidreadFile(String filePath) \{

InfoBean infoBean= newInfoBean();try\{

String encodeing= "GBK";

File file= newFile(filePath);if (file.isFile() &&file.exists()) \{

InputStreamReader isr= new InputStreamReader(newFileInputStream(file), encodeing);

BufferedReader bufferedReader= newBufferedReader(isr);

String lineTxt= null;

OperationDB opdb= newOperationDB();while ((lineTxt = bufferedReader.readLine()) != null) \{

String\[\] s= lineTxt.split(",");//System.out.println(s\[0\].toString() + s\[1\].toString() + s\[2\].toString() + s\[3\].toString() );

infoBean.setTimeStamp(s\[0\].toString());

infoBean.setElapsed(s\[1\].toString());

infoBean.setGrpThreads(s\[2\].toString());

infoBean.setAllThreads(s\[3\].toString());

opdb.addRcorder(infoBean);

System.out.println(lineTxt);

isr.close();

\}else\{

System.out.println("not found specific file");

\}catch(Exception e) \{

System.out.println("read file content error");

e.printStackTrace();

创建连接

packagecollect\_part;importjava.sql.Connection;importjava.sql.DriverManager;importjava.sql.SQLException;importjava.util.logging.Level;importjava.util.logging.Logger;public classMysqlConnection \{public staticConnection getConnection() \{

Connection conn= null;

String url= "jdbc:mysql://10.1.1.148:3306/testresults";

String user= "user";

String password= "passwd";try\{

conn=DriverManager.getConnection(url, user, password);

\}catch(SQLException ex) \{

Logger.getLogger(MysqlConnection.class.getName()).log(Level.SEVERE,null, ex);

\}returnconn;

操作数据库

packagecollect\_part;importjava.sql.Connection;importjava.sql.PreparedStatement;importjava.sql.SQLException;importjava.util.logging.Level;importjava.util.logging.Logger;public classOperationDB \{private Connection conn = null;public void addRcorder(InfoBean infoBean) throwsSQLException \{if (conn == null) \{

conn=MysqlConnection.getConnection();

String sql= "INSERT INTO cpuInfo (\`timeStamp\`, \`elapsed\`, \`grpThreads\`, \`allThreads\`) VALUES (?, ?, ?, ?)";

PreparedStatement pstmt=conn.prepareStatement(sql);

pstmt.setLong(1, infoBean.getTimeStamp());

pstmt.setLong(2, infoBean.getElapsed());

pstmt.setLong(3, infoBean.getGrpThreads());

pstmt.setLong(4, infoBean.getAllThreads());

pstmt.executeUpdate();

记录信息

packagecollect\_part;

public classInfoBean \{longtimeStamp;longelapsed;longgrpThreads;longallThreads;public longgetTimeStamp() \{returntimeStamp;

\}public voidsetTimeStamp(String timeStamp) \{this.timeStamp =Long.parseLong(timeStamp);