根据deve这个字段分组,根据时间time字段排序,取最后一条statusType字段值为130101和010101的值,sql怎么写
时间: 2023-05-25 08:03:50 浏览: 30
SELECT *
FROM (
SELECT *,
ROW_NUMBER() OVER (
PARTITION BY deve
ORDER BY time DESC
) AS row_num
FROM your_table
WHERE statusType IN ('130101', '010101')
) t
WHERE row_num = 1;
相关问题
sparksql 根据一个字段生成id,固定的值对应固定的id主键 sql语句
如果你的需求是根据一个字段生成 ID,并且每个固定的值都对应一个固定的 ID,可以使用 SparkSQL 中的 CASE WHEN 语句来实现。同时,如果你需要将生成的 ID 作为主键,可以使用 SparkSQL 中的 `PRIMARY KEY` 约束来实现。以下是示例代码:
```scala
import org.apache.spark.sql.functions.{row_number, when}
import org.apache.spark.sql.expressions.Window
val df = Seq(("Alice", "female"), ("Bob", "male"), ("Charlie", "male"), ("Eve", "female")).toDF("name", "gender")
val window = Window.partitionBy("gender").orderBy("name")
val result = df.withColumn("id", when($"gender" === "female", row_number().over(window) + 1000)
.otherwise(row_number().over(window)))
.withColumn("id", $"id".cast("String")) // 将 ID 转换为字符串类型
.withColumn("id", concat($"gender", $"id")) // 使用 gender 字段作为前缀
.drop("gender")
.withColumnRenamed("id", "pk") // 将 id 字段重命名为 pk
.withColumn("name", $"name".cast("String")) // 将 name 字段转换为字符串类型
.select("pk", "name")
.distinct()
.orderBy("pk")
.createOrReplaceTempView("temp_table")
spark.sql("CREATE TABLE my_table (pk STRING PRIMARY KEY, name STRING) USING PARQUET")
spark.sql("INSERT INTO my_table SELECT * FROM temp_table")
```
这个示例代码的含义是:首先根据 gender 字段生成 ID,以 gender 字段加上 ID 作为主键,并将 ID 作为字符串类型。然后将 gender 字段删除,将 ID 字段重命名为 pk,并保存到一个临时表中。最后使用 CREATE TABLE 语句创建一张表,并将临时表中的数据插入到该表中。注意,这里使用了 `USING PARQUET` 选项来指定表的数据格式,你也可以根据实际情况来选择其他数据格式。
sparksql 根据一个字段生成id,固定的值对应固定的id sql语句
如果你的需求是根据一个字段生成 ID,并且每个固定的值都对应一个固定的 ID,可以使用 SparkSQL 中的 CASE WHEN 语句来实现。以下是示例代码:
```scala
import org.apache.spark.sql.functions.{row_number, when}
import org.apache.spark.sql.expressions.Window
val df = Seq(("Alice", "female"), ("Bob", "male"), ("Charlie", "male"), ("Eve", "female")).toDF("name", "gender")
val window = Window.partitionBy("gender").orderBy("name")
val result = df.withColumn("id", when($"gender" === "female", row_number().over(window) + 1000)
.otherwise(row_number().over(window)))
result.show()
```
这个示例代码的含义是:当 `gender` 字段的值为 "female" 时,使用 `row_number()` 函数生成 ID,并加上 1000;当 `gender` 字段的值不为 "female" 时,直接使用 `row_number()` 函数生成 ID。这样就可以实现每个固定的值对应固定的 ID 的需求。输出结果为:
```
+-------+------+----+
| name|gender| id|
+-------+------+----+
| Alice|female|1001|
| Eve|female|1002|
| Bob| male| 1|
|Charlie| male| 2|
+-------+------+----+
```