SQL语法过滤|学习笔记

简介: 快速学习SQL语法过滤

开发者学堂课程【RocketMQ知识精讲与项目实战(第一阶段)SQL语法过滤】学习笔记,与课程紧密联系,让用户快速学习知识

课程地址:https://developer.aliyun.com/learning/course/702/detail/12388


SQL语法过滤

 

内容介绍:

一、绑定属性

二、限制条件

 

一、绑定属性

结构还是一个生产者和一个消费者,consumer 和 producer 主题改为filtersqltopic,再给消息绑定一个自定义的属性,

代码示例:

producer.start();

for (int i = 0; i < 10; i++) {

//4.创建消息对象,指定主 题Topictog 和消息体

/**

*一:消息主题 Topic

*二:消息Tag

*参数:消息内容

*/

Messagemsg=new Message(topic: “FilterSQLTopic”,taqs:"Tag1”,(“Hello World*+i).getBytes());

msg.putuerProperty( name:’’i’’string,valueof(i));

//5.发送消息

SendResult result = producer.send(msg);

//发送状态

Sendstatus status=result.getSendstatus();

System.out.println("发送结果:"+result);

//线程睡一秒

TimeUnit.SECONDS.sleep(timeout1);

}

//16.闭生产producer

pnoducer.shutdowm();

}

 

二、限制条件

启动消费者,限制条件为i>5,因此可以得到发送了i为6、7、8、9的消息,

public class consumer{

public static void main(String[] args) throws Exception {

//1.创建消费者Consumer,指定消费者组名

DefaultNOPushConsumerconsumer=newDefaultMQPushConsumer(consumerGroup: “group1”);

//2.指定 nameserver 地址

consumer.setNamesrvAddr("192.168.25 .135:9876;192.168.25.138:9876);

//3.订阅主题TopicTag

consumer.subscribe(topic:"FiltersQLTopic”,

MessageSelector.bySql("i>5"));

//设置回调函数,处理消息

consumer.registerMessageListener((MessageListenerConcurrently)(msgs;context){

for (MessageExt msg :msgs){

System.out.println("consumeThreadm=”+Thread.currentThread()-getName() +","*+new string(msg.getbody()));

return ConsumeConcurrentlystatus.CONSUME_SUCCESS;

})

Consumer :

consuneThread=ConsumeMessageThread_1,Hello world 6

consumeThread=ConsumeMessageThread_2,Helloworld7 consumeThreed=ConsumeMessageThread 3 Hello world8

consumeThread=ConsumeMessageThread_4,Hello World9

虽然对方发送了十条,但根据用户的属性,过滤了消息,这就是由 sql 过滤得到

的。

相关文章
|
15天前
|
算法 数据挖掘 数据库
通过 SQL 快速使用 OceanBase 向量检索学习笔记
通过 SQL 快速使用 OceanBase 向量检索学习笔记
|
22天前
|
SQL 数据库
SQL 学习笔记 - 多表关系与多表查询
数据库多表关系包括一对多、多对多和一对一,常用外键关联。多表查询方式有隐式/显式内连接、外连接、子查询等,支持别名和条件筛选。子查询分为标量、列、行、表子查询,常用于复杂查询场景。
|
10月前
|
SQL 存储 关系型数据库
【MySQL基础篇】全面学习总结SQL语法、DataGrip安装教程
本文详细介绍了MySQL中的SQL语法,包括数据定义(DDL)、数据操作(DML)、数据查询(DQL)和数据控制(DCL)四个主要部分。内容涵盖了创建、修改和删除数据库、表以及表字段的操作,以及通过图形化工具DataGrip进行数据库管理和查询。此外,还讲解了数据的增、删、改、查操作,以及查询语句的条件、聚合函数、分组、排序和分页等知识点。
817 55
【MySQL基础篇】全面学习总结SQL语法、DataGrip安装教程
|
SQL 关系型数据库 MySQL
MySQL数据库基础第一篇(SQL通用语法与分类)
MySQL数据库基础第一篇(SQL通用语法与分类)
|
SQL PHP
thinkphp之进阶sql语法,持续更新
thinkphp之进阶sql语法,持续更新
112 0
|
11月前
|
SQL 存储 关系型数据库
SQL `CREATE DATABASE` 语法
【11月更文挑战第10天】
299 3
|
11月前
|
SQL 关系型数据库 数据库
sql语法
【10月更文挑战第26天】sql语法
150 5
|
12月前
|
SQL 数据库
SQL数据库基础语法入门
[link](http://www.vvo.net.cn/post/082935.html)
|
12月前
|
SQL 存储 关系型数据库
mysql SQL必知语法
本文详细介绍了MySQLSQL的基本语法,包括SELECT、FROM、WHERE、GROUPBY、HAVING、ORDERBY等关键字的使用,以及数据库操作如创建、删除表,数据类型,插入、查询、过滤、排序、连接和汇总数据的方法。通过学习这些内容,读者将能更好地管理和操
247 0
|
12月前
|
SQL 关系型数据库 MySQL
Mysql(2)—SQL语法详解
SQL(Structured Query Language,结构化查询语言)是一种用于管理关系型数据库的标准编程语言。它主要用于数据的查询、插入、更新和删除等操作。SQL最初在1970年代由IBM的研究人员开发,旨在处理关系数据模型。
133 0