PyODPS学习:使用DataFrame实现SQL的IF判断

简介: 使用DataFrame实现SQL的IF判断

在编写SQL代码时,可能会遇到这种场景(假如有两个字段column1,column2,当字段1小于某个值时,字段2等于0).
1.sql语句可以使用CASE WHEN:

SELECT
    column1,
    (CASE WHEN column1<10 THEN 0 ELSE column2 END) AS column2
FROM tabelName;

2.使用IF语句

SELECT
    column1,
     IF(column1<10,0,column2) AS column2
FROM tabelName;

那这种情况在PyODPS的DataFrame对象怎么操作呢?

from odps.df import DataFrame

#运行时显示详细信息
from odps import options
options.verbose = True

OdpsTable=odps.get_table('**一个表**')
InitialData = DataFrame(OdpsTable)
InitialData[InitialData['column1']<10,'column2']=0

其实ODPS是执行了IF语句,并返回了一个新表重新赋值给了InitialData。可以将options.verbose = True,查看PyODPS与ODPS交互过程中运行的命令。
更多技巧参考文档:http://pyodps.readthedocs.io/zh_CN/latest/df-basic-zh.html

目录
相关文章
|
3月前
|
SQL 缓存 关系型数据库
MySQL技能完整学习列表6、查询优化——3、查询缓存——4、SQL优化技巧
MySQL技能完整学习列表6、查询优化——3、查询缓存——4、SQL优化技巧
65 0
|
4月前
|
SQL 测试技术 项目管理
轻松学习SQL外键约束的核心原理和实用技巧
轻松学习SQL外键约束的核心原理和实用技巧
49 0
|
5月前
|
SQL 分布式计算 数据库
【大数据技术Spark】Spark SQL操作Dataframe、读写MySQL、Hive数据库实战(附源码)
【大数据技术Spark】Spark SQL操作Dataframe、读写MySQL、Hive数据库实战(附源码)
106 0
|
3月前
|
SQL 关系型数据库 MySQL
MySQL技能完整学习列表3、SQL语言基础——1、SQL(Structured Query Language)简介——2、基本SQL语句:SELECT、INSERT、UPDATE、DELETE
MySQL技能完整学习列表3、SQL语言基础——1、SQL(Structured Query Language)简介——2、基本SQL语句:SELECT、INSERT、UPDATE、DELETE
51 0
|
5月前
|
SQL 分布式计算 数据挖掘
Spark_Day07:Spark SQL(DataFrame是什么和数据分析(案例讲解))
Spark_Day07:Spark SQL(DataFrame是什么和数据分析(案例讲解))
78 0
|
2月前
|
SQL 数据库 内存技术
学习数据库要掌握的54条SQL查询语句
学习数据库要掌握的54条SQL查询语句
15 0
|
3月前
|
SQL 安全 关系型数据库
MySQL技能完整学习列表3、SQL语言基础——3、SQL运算符和函数
MySQL技能完整学习列表3、SQL语言基础——3、SQL运算符和函数
38 0
|
4月前
|
SQL Java 关系型数据库
JDBC技术【SQL注入、JDBC批量添加数据、JDBC事务处理、其他查询方式】(三)-全面详解(学习总结---从入门到深化)
JDBC技术【SQL注入、JDBC批量添加数据、JDBC事务处理、其他查询方式】(三)-全面详解(学习总结---从入门到深化)
33 0
|
5月前
|
存储 SQL Oracle
|
5月前
|
SQL
SQL高阶学习
SQL高阶学习
17 0

热门文章

最新文章