使用MySQL会话变量实现窗口函数

一、MySQL窗口函数

(1) 序号函数

row_number()在相等的两条记录上随机排序,但序号按照1、2递增,然后后面的序号继续递增为3,中间不会产生序号间隙;

rank()/dense_rank()则把前两条相等的记录序号都设置为1,但后续则分别设置为3(rank)和2(dense_rank)。即rank()会产生序号相同的记录,同时可能产生序号间隙;而dense_rank()也会产生序号相同的记录,但不会产生序号间隙。

(2) 分布函数

percent_rank()

  • 用途:和之前的RANK()函数相关,每行按照如下公式进行计算:
  • (rank - 1) / (rows - 1)
  • 其中,rank为RANK()函数产生的序号,rows为当前窗口的记录总行数。
  • 应用场景:很少。

cume_dist()

  • 用途:分组内小于等于当前rank值的行数/分组内总行数,这个函数比percen_rank使用场景更多。
  • 应用场景:大于等于当前订单金额的订单比例有多少

(3) 前后函数

前后函数——lead(n)/lag(n)。

  • 用途:分区中位于当前行前n行(lead)/后n行(lag)的记录值。
  • 使用场景:查询上一个订单距离当前订单的时间间隔。

SQL如下:

内层SQL先通过lag函数得到上一次订单的日期,外层SQL再将本次订单和上次订单日期做差得到时间间隔diff。

(4) 头尾函数

头尾函数——first_val(expr)/last_val(expr)。

  • 用途:得到分区中的第一个/最后一个指定参数的值。
  • 使用场景:查询截止到当前订单,按照日期排序第一个订单和最后一个订单的订单金额。

SQL如下:

结果和预期一致,比如order_id为4的记录,first_amount和last_amount分别记录了用户‘001’截止到时间2018-01-03 00:00:00为止,第一条订单金额100和最后一条订单金额800,注意这里是按时间排序的最早订单和最晚订单,并不是最小金额和最大金额订单。

(5) 其他函数

其他函数——nth_value(expr,n)/nfile(n)。

nth_value(expr,n)

  • 用途:返回窗口中第N个expr的值,expr可以是表达式,也可以是列名。
  • 应用场景:每个用户订单中显示本用户金额排名第二和第三的订单金额。

SQL如下:

nfile(n)

  • 用途:将分区中的有序数据分为n个桶,记录桶号。
  • 应用场景:将每个用户的订单按照订单金额分成3组。

SQL如下:

此函数在数据分析中应用较多,比如由于数据量大,需要将数据平均分配到N个并行的进程分别计算,此时就可以用NFILE(N)对数据进行分组,由于记录数不一定被N整除,所以数据不一定完全平均,然后将不同桶号的数据再分配。

(6) 聚合函数作为窗口函数

  • 用途:在窗口中每条记录动态应用聚合函数(sum/avg/max/min/count),可以动态计算在指定的窗口内的各种聚合函数值。
  • 应用场景:每个用户按照订单id,截止到当前的累计订单金额/平均订单金额/最大订单金额/最小订单金额/订单数是多少?

SQL如下:

除了这几个常用的聚合函数,还有一些也可以使用,比如BIT_AND()、STD()等等,具体查看官方文档。

 二、MySQL变量

MySQL入门 SQL语言之十八:系统变量(全局变量、会话变量),自定义变量(用户变量、局部变量)的使用
#变量
/*
系统变量:
    全局变量
    会话变量
自定义变量:
    用户变量
    局部变量
*/
#一、系统变量
/*
说明:变量由系统提供,不是用户定义,属于服务器层面
使用的语法:
1、查看所有的系统变量
show global variables;
SHOW session VARIABLES;#session可以省略

2、查看满足条件的部分系统变量
show VARIABLES variables like ‘%char%‘;

3、查看指定的某个系统变量值
select @@global|【session】.系统变量名;

4、为某个系统变量赋值
方式一:
set global|【session】 系统变量名 = 值;
set autocommit = 0;

方式二:
set @@global|【session】.系统变量名 = 值;

注意:
如果是全局级别,则需要加global,如果是会话级别,则需要加session,如果不写,则默认session

*/
#1》、全局变量
/*
作用域:服务器每次启动将为所有的全局变量赋初始值,针对于所有会话(连接)有效,但是不能跨重启。
如果要想每次启动也修改,则需要修改配置文件。
*/
#①查看所有的全局变量
SHOW GLOBAL VARIABLES;

#②查看部分的全局变量
SHOW GLOBAL VARIABLES LIKE ‘%char%‘;

#③查看指定的全局量的值
SELECT @@global.autocommit;
SELECT @@tx_isolation;

#④为某个指定全局变量赋值
#方式一:
SET @@global.autocommit = 0;
#方式二:
SET GLOBAL autocommit = 0;
#2》、会话变量
/*
作用域:仅仅针对于当前会话(连接)有效,并且有默认值
*/

#①查看所有的会话变量;
SHOW SESSION VARIABLES;
SHOW  VARIABLES;

#②查看部分的会话变量
SHOW  VARIABLES LIKE ‘%char%‘;
SHOW SESSION VARIABLES  LIKE ‘%char%‘;

#③查看指定的某个会话变量
SELECT @@tx_isolation;
SELECT @@session.tx_isolation;

#④为某个会话变量赋值
#方式一
SET @@session.tx_isolation = ‘read-uncommitted‘;
#方式二:
SET SESSION tx_isolation =  ‘read-committed‘;

#二、自定义变量
/*
说明:变量是用户自定义的,不是由系统的

使用步骤
声明
赋值
使用(查看、比较、运算等)
*/
#1、用户变量
/*
作用域:针对于当前会话(连接)有效,同于会话变量的作用域
应用在任何地方,也就是begin end里面或begin end外边
*/
赋值的操作符: = 或 :=
#①声明并初始化
SET @用户变量名 = 值;
SET @用户变量名 := 值;
SELECT @用户变量名 :=值;

#②赋值(更新用户变量的值)
方式一: 通过SET或SELECT
    SET @用户变量名 = 值;
    SET @用户变量名 := 值;
    SELECT @用户变量名 :=值;
方式二:通过SELECT INTO
    SELECT 字段 INTO @变量名
    FROM 表;
#③使用(查看用户变量名的值)    
SELECT @用户变量名;

#2、局部变量
/*
作用域:仅仅在定义它的begin end中有效
应用在begin end中的第一句话
*/
#①声明
DECLARE 变量名 类型;
DECLARE 变量名 类型 DEFAULT 值;
#②赋值
方式一: 通过SET或SELECT
    SET 局部变量名 = 值;
    SET 局部变量名 := 值;
    SELECT @局部变量名 :=值;
方式二:通过SELECT INTO 局部变量名
    SELECT 字段
#③使用
SELECT 局部变量名;

#案例:
#声明并初始化
SET @name = ‘john‘;
SET @name = 100;
SET @count = 1;
#赋值
SELECT COUNT(*) INTO @count 
FROM employees;
#查看
SELECT @count;

对比用户变量和局部变量

作用域 定义和使用的位置  语法
用户变量 当前的会话 会话中的任何地方 必须加@符号,不限定类型
局部变量  BEGIN END中 只能在BEGIN END中,且为第一句 一般不加@符号,需限定类型

#案例:声明两个变量并赋初始值,就和,并打印
#1.用户变量
SET @m=1;
SET @n=2;
SET @sum = @[email protected];
SELECT @sum;
#2.局部变量
    DECLARE m INT DEFAULT 1;
    DECLARE n INT DEFAULT 2;
    DECLARE SUM INT;
    SET SUM = m + n;
    SELECT SUM;

#报错

本文转载自:

http://www.sohu.com/a/260324504_411876

https://blog.csdn.net/qq_34626097/article/details/86528466;

原文地址:https://www.cnblogs.com/dlp-527/p/11701505.html

时间: 2024-10-14 14:24:54

使用MySQL会话变量实现窗口函数的相关文章

深入MySQL用户自定义变量:使用详解及其使用场景案例

一.前言 在前段工作中,曾几次收到超级话题积分漏记的用户反馈.通过源码的阅读分析后,发现问题出在高并发分布式场景下的计数器上.计数器的值会影响用户当前行为所获得积分的大小.比如,当用户在某超级话题下连续第n(n即计数器的值)次进行转发帖子时,将会获得与n相关的分数.然而,在第一次改进后问题依然存在.所以,这次在之前的基础上,通过使用MySQL变量的途径来解决该问题. 二.到底MySQL的变量分哪几类? MySQL变量一共分为两大类:用户自定义变量和系统变量.如下: 用户自定义变量 局部变量 会话

MySQL 系统变量(system variables)

MySQL系统变量(system variables)实际上是一些系统参数,用于初始化或设定数据库对系统资源的占用,文件存放位置等等.这些个系统变量可以分为全局以及会话级别层面来修改,有些也可以进行动态修改.本文主要介绍了系统变量的一些概念以及如何设置查看这些系统变量. 1.什么是系统变量   系统变量实际上用于控制数据库的一些行为和方式的参数.比如我们启动数据库的时候设定多大的内存,使用什么样的隔离级别,日志文件的大小,存放位置等等一系列的东东.当然我们数据库系统启动后,有些系统变量(参数)也

mysql系统变量查询

mysql系统变量包括全局变量(global)和会话变量(session),global变量对所有session生效,session变量包括global变量.mysql调优必然会涉及这些系统变量的调整,所以我们首先得会查询系统变量. 1. 查询全局变量:show global variables \G; 2. 查询会话变量:show session variables \G;或show variables: 可以看到,变量表包含variable_name,value两个字段,所以可以通过这两个字

MySQL中变量的总结

本文对MySQL中局部变量.用户变量.系统变量的理解进行总结. 一.局部变量 局部变量由DECLARE语句声明: DECLARE var_name[,...] type [DEFAULT value] 默认值由DEFAULT子句来声明,默认值也可以是一个表达式. 局部变量的作用范围仅限在它被声明的BEGIN...END块内,当语句执行完毕,局部变量就消失了. 二.用户变量 可以先在用户变量中保存值然后在以后引用它:这样可以将值从一个语句传递到另一个语句.用户变量与连接有关.也就是说,一个客户端定

MySQL系统变量

在数据库中,变量分为系统变量(以'@@'开头)以及用户自定义变量.系统变量分为全局系统变量以及会话系统变量,静态变量属于特殊的全局系统变量. 全局系统变量(global)和会话系统变量(session),有时也把全局系统变量称为全局变量,把会话系统变称为local变量或者系统会话变量.Mysql服务成功启动后,如果没有mysql客户机连接mysql服务器,那么mysql服务器内存中的系统变量全部是全局系统变量. 每个mysql客户机成功连接mysql服务器后,都会产生与之对应的会话.会话期间,没

mysql服务器变量

mysql的服务器变量 MySQL服务器维护了两大类变量,一个是服务器变量,另一个是状态变量.其中: 服务器变量: 定义MySQL服务器运行特性                1. mysql服务器变量根据作用域可以分为全局变量和会话变量: 全局变量: #SHOW GLOBAL VARIABLES [LIKE 'STRING']; #使用该命令可以显示某个服务所有的全局变量及其值 会话变量: #SHOW [SESSION] VARIABLES [LIKE 'STRING'] #使用该命令可以显示

mysql之变量

mysql的变量:    服务器变量:        使用参数改变mysql运行特性.即配置文件中的定义的指令. 查看服务器变量:            mysql>SHOW [GLOBAL] [SESSION] VARIABLES [LIKE 'STRING'] ;            mysql> SELECT @@ GLOBAL|[SESSION] STRING; 修改服务变量:            mysql>SET GLOBAL|SESSION STRING='VALUE'

MySQL 服务器变量 数据操作DML-视图

SQL语言的组成部分 常见分类: DDL:数据定义语言 DCL:数据控制语言,如授权 DML:数据操作语言 其它分类: 完整性定义语言: DDL的一部分功能约束 约束:包括主键,外键,唯一键,条件,非空,事务等各类约束 视图定义:即虚表,就是存储下来的SELECT语句 事务控制 嵌入式SQL和动态SQL 数据字典:系统编目(system catalog) 作用:保存数据库服务器上的元数据 保存元数据的数据库有: information_schema mysql performance_schem

MySQL - 用户变量

MySQL用户变量:基于会话变量实现的,可以暂存值,并传递给同一连接里的下一条sql使用的变量,当客户端连接退出时,变量会被释放. MySQL用户变量应用场景:同一连接,未关闭情况下,帮你暂存一些计算结果. 两种方式定义用户变量: 1. "=" 如 set @a = 3 , @a: = 5 2. ":=" select常常这样使用. 总结:使用select和set设置变量的区别,set可以使用以上两种形式设置变量,而select只能使用":="的