大数据基本的 增删改差 Demo（资源来自网络本人属于收藏总结）

Posted 2020-10-27 zhbx

今天第一天接触大数据 做一些基本的增删改差，来这总结一下 ，资源来自网络本人属于收藏总结

这一篇只有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 }

运行前的数据库 

 

运行后

 

后台打印