个人技术分享

kafka-重试和死信主题（SpringBoot整合Kafka）

在Kafka中，DLT通常指的是 。Dead Letter Topic（DLT）的定义与功能：DLT的使用与意义：总之，在Kafka中，DLT是一个用于处理无法被成功消费的消息的特殊Topic，它提供了一种灵活且可靠的机制来保障Kafka系统的稳定性和可靠性。3.2、引入spring-kafka依赖3.3、创建SpringBoot启动类3.4、创建生产者发送消息3.5、创建消费者消费消息

【Hive SQL 每日一题】统计各个商品今年销售额与去年销售额的增长率及排名变化

惯性思维导致，在排序中，并不是排名越高值越大，相反，因为我们的排名越靠前（越高），其排名值越小，想到这里，就应该明白了。（2）根据（1）中的结果，通过窗口函数排序，获取分别获取两个年度的销售额排名。（3）根据（2）中的结果，判断并计算两个年度的增长率以及排名变化，最终通过。统计各个商品今年销售额与去年销售额的增长率及销售额的排名变化。（1）获取去年与今年两个年度的数据，并进行聚合统计。可能对于排名那里存在疑惑，为什么是。连接商品表，获取商品名称。

多表连接查询和子查询

在上面的连接规则表达式中，字段名前加上了数据表的名称，并用英文中的句号（.）将其隔开，这是因为两个表中有相同的字段名，如果不加以修饰说明，DBMS将无法辩认是哪个表的字段；CREATE TABLE bxk_score AS SELECT stu_info.id as 学号,stu_info.name AS 姓名,stu_course.ID AS 课号,stu_course.course AS 课名。有连接规则连接其实就是在无连接规则的基础上，加上WHERE子句指定连接规则的连接方法。

springAOP 使用aop代替SqlsessionUtil业务层操作

第一种方式是针对service包所有的方法，包括增删改和查询操作，但是查询操作使用线程提交回滚是非必要的，可以修改配置文件,只针对增删改操作进行线程提交和回滚操作。环绕通知实际上就是一个动态代理方法的重写，可以看到格式和jdk动态代理，cglib动态代理一样。在执行目标对象方法前使用前置通知拿到方法名，判断是否是查询操作在进行后置通知的提交回滚操作。添加之后可以使用aop的其他注解：@Pointcut；@Before...@Aspect表明这是一个切面，

Flask sqlalchemy 运行时报错：ModuleNotFoundError: No module named ‘MySQLdb‘

Flask sqlalchemy 运行时报错：ModuleNotFoundError: No module named 'MySQLdb'。查询原因发现是表示 Python 环境中缺少名为 MySQLdb 的模块。MySQLdb 是一个 Python 的 MySQL 数据库接口，它是 MySQL 官方支持的数据库驱动之一。虽然解决了但是感觉很奇怪，因为之前也是用的pymysql，没有指定驱动一样能连接。不知道是不发falsk或者flask-sqlalchemy 的版本更新导致的。

MySQL优化器的SQL重写规则

优化器在分析一个查询语句时，先首先执行常量表查询，然后把查询中涉及到该表的条件全部替换成常数，最后再分析其余表的查询成本。对于列子查询和表子查询来说，它们的结果集中包含很多条记录，这些记录相当于是一个集合，所以就不能单纯的和另外一个操作数使用操作符来组成布尔表达式了，MySQL通过下面的语法来支持某个操作数和一个集合组成一个布尔表达式。所谓物化表转连接，就是外层表和物化表做连接查询，MySQL通过计算外层表作为驱动表和物化表作为驱动表进行连接查询的查询成本，然后使用成本较低的方式进行查询。