今天第一天接触大数据 做一些基本的增删改差，来这总结一下 ，资源来自网络本人属于收藏总结
这一篇只有demo合运行结果 ，下一篇有一点对代码的分析合自己的理解
先看一下数据库 的数据
查询数据
1 public static void main(String args[]) throws TRSException {
2 TRSConnection conn = new TRSConnection("http://127.0.0.1:5555", "admin", "trsadmin", new ConnectParams());
3 SearchParams param = new SearchParams();
4 param.setReadColumns("rowid;日期;标题;作者;正文");
5 param.setColorColumns("正文");
6 param.setCutSize(200);
7 TRSResultSet resultSet = conn.executeSelect("demo", "正文:街舞", 0, 10, param);
8
9 System.out.println(resultSet.getNumFound() + " records found");
10 for (int i = 0; i < resultSet.size(); i++) {
11 resultSet.moveNext();//移动到检索结果记录集的下一条记录。
12 TRSRecord re = resultSet.get();
13 System.out.println();
14 System.out.println("result_" + i);
15 System.out.println("rowid:" + re.getString("rowid"));
16 System.out.println("日期:" + re.getString("日期"));
17 System.out.println("标题:" + re.getString("标题"));
18 System.out.println("作者:" + re.getString("作者"));
19 System.out.println("正文:" + re.getString("正文"));
20 }
21 conn.close();
22 }
后台输出结果
增加数据
1 public class DemoAdd {
2
3 /**
4 * @param args
5 * @throws TRSException
6 */
7 public static void main(String[] args) throws TRSException {
8 // TODO Auto-generated method stub
9 TRSConnection conn = new TRSConnection("http://127.0.0.1:5555", "admin", "trsadmin", new ConnectParams());
10 List<TRSInputRecord> recordList = new ArrayList<TRSInputRecord>();
11 TRSInputRecord record_1 = new TRSInputRecord();
12 record_1.addColumn("rowid", "1");
13 record_1.addColumn("日期", "2018-03-15");
14 record_1.addColumn("版次", "1");
15 record_1.addColumn("版名", "娱乐");
16 record_1.addColumn("标题", "街舞少年尬舞，输的要吃要吃掉对方的帽子");
17 record_1.addColumn("作者", "张邦煊");
18 record_1.addColumn("正文", "新疆乌鲁木齐街舞少年 日前在南湖广场高调尬舞，扬言输掉要吃掉对方的帽子");
19 recordList.add(record_1);
20
21 TRSInputRecord record_2 = new TRSInputRecord();
22 record_2.addColumn("rowid", "2");
23 record_2.addColumn("日期", "2018.3.15");
24 record_2.addColumn("版次", "3 ");
25 record_2.addColumn("版名", "娱乐");
26 record_2.addColumn("标题", "ks舞社再次蝉联九届WID冠军");
27 record_2.addColumn("作者", "张邦煊");
28 record_2.addColumn("正文", "ks舞社队长 嘎子说：“我们已经是连续九届的冠军了， 拿的手都软了”");
29 recordList.add(record_2);
30
31 OperationParams params = new OperationParams();
32 params.setBoolProperty("insert.skip.error", true);
33 TRSReport report = new TRSReport();
34 try {
35 conn.executeInsert("demo", recordList,params, report);//插入数据 demo表名 recordList数据
36 conn.commitDatabase("demo", new OperationParams());//提交
37 System.out.println("insert records:" + report.getInsertedNum());//插入成功的数目 如果 executeInsert方法不写 后面的两个参数 则此处置为 0
38 } catch (TRSException e) {
39 System.out.println(e.getErrorCode() + ":" + e.getErrorString());
40 } finally {
41 conn.close();
42 }
43 }
44
45
46
47 }
这个就不运行了
删除数据
public class DemoDel {
/**
* @param args
* @throws TRSException
*/
public static void main(String[] args) throws TRSException {
// TODO Auto-generated method stub
TRSConnection conn = new TRSConnection("http://127.0.0.1:5555", "admin", "trsadmin", new ConnectParams());
SearchParams param = new SearchParams();
param.setReadColumns("rowid;日期;标题;作者;正文");
param.setColorColumns("标题");//高亮显示
param.setCutSize(200);
TRSResultSet resultSet = conn.executeSelect("demo", "版次:1", 0, 10, param);
System.out.println(resultSet.getNumFound());
// for (int i = 0; i < resultSet.size(); i++) {
// resultSet.moveNext();//移动到检索结果记录集的下一条记录。
// TRSRecord re = resultSet.get();
// System.out.println();
// System.out.println("result_" + i);
// System.out.println("rowid:" + re.getString("rowid"));
// System.out.println("日期:" + re.getString("日期"));
// System.out.println("标题:" + re.getString("标题"));
// System.out.println("作者:" + re.getString("作者"));
// System.out.println("正文:" + re.getString("正文"));
// }
for (int i = 0; i < resultSet.size(); i++) {
resultSet.moveNext();
TRSRecord re = resultSet.get();
conn.executeDelete("demo", re.getUid());
}
conn.close();
}
}
后台结果
数据库的结果
修改数据
1 public class DemoUpdate {
2
3 /**
4 * @param args
5 * @throws TRSException -
6 */
7 public static void main(String[] args) throws TRSException {
8 // TODO Auto-generated method stub
9 TRSConnection conn = new TRSConnection("http://127.0.0.1:5555", "admin", "trsadmin", new ConnectParams());
10 SearchParams sParams = new SearchParams();
11 TRSResultSet resultSet = conn.executeSelect("demo", "版名:娱乐", 0, 1, sParams);//查询
12 System.out.println(resultSet.getNumFound());
13 resultSet.moveNext();//下一个
14 TRSRecord re = resultSet.get();//取当前一条记录
15 TRSInputRecord updated = new TRSInputRecord();
16 updated.setUid(re.getUid());
17 updated.addColumn("正文", "update=================");
18 ArrayList<TRSInputRecord> updateList = new ArrayList<TRSInputRecord>(1);
19 updateList.add(updated);
20 OperationParams uParams = new OperationParams();
21 uParams.setProperty("update.mode.replace", "false");
22 conn.executeUpdate("demo", updateList,uParams,new TRSReport());
23 conn.close();
24
25
26
27 }
28
29 }
运行前的数据库
运行后
后台打印
原文地址：https://www.cnblogs.com/zhbx/p/8573097.html
时间： 2024-10-21 18:34:49