Java 8 Friday:不再需要ORM

在Data Geekery ,我们喜欢Java。 而且,由于我们真的很喜欢jOOQ的流畅的API和查询DSL ,我们对Java 8将为我们的生态系统带来什么感到非常兴奋。

Java 8星期五

每个星期五,我们都会向您展示一些不错的教程风格的Java 8新功能,这些功能利用了lambda表达式,扩展方法和其他好东西。 您可以在GitHub上找到源代码 。

不再需要ORM

在过去的十年中,关于ORM(对象关系映射)的有用性的争论一直在进行。 尽管许多人会同意Hibernate和JPA很好地解决了许多问题(大多数情况是复杂对象图的持久性),但其他人可能会认为, 映射复杂性对于以数据为中心的应用程序来说大多数是过分的 。

JPA通过在接收目标类型上使用硬连线的注释建立标准化的声明性映射规则来解决映射问题。 我们声称,许多以数据为中心的问题不应仅受这些注释的狭窄范围的限制,而应以更加实用的方式解决。 Java 8和新的Streams API最终使我们能够以非常简洁的方式执行此操作!

让我们从一个简单的示例开始,在该示例中,我们使用H2的INFORMATION_SCHEMA收集所有表及其列。 我们将要生成一个Map<String, List<String>>类型的临时数据结构来包含此信息。 为了简化SQL交互,我们将使用jOOQ (与往常一样,此博客上的内容令人震惊)。 这是我们准备的方法:

public static void main(String[] args)
throws Exception {Class.forName("org.h2.Driver");try (Connection c = getConnection("jdbc:h2:~/sql-goodies-with-mapping", "sa", "")) {// This SQL statement produces all table// names and column names in the H2 schemaString sql ="select table_name, column_name " +"from information_schema.columns " +"order by " +"table_catalog, " +"table_schema, " +"table_name, " +"ordinal_position";// This is jOOQ's way of executing the above// statement. Result implements List, which// makes subsequent steps much easierResult<Record> result =DSL.using(c).fetch(sql)}
}

现在我们已经设置了该查询,让我们看看如何从jOOQ Result中生成Map<String, List<String>>

DSL.using(c).fetch(sql).stream().collect(groupingBy(r -> r.getValue("TABLE_NAME"),mapping(r -> r.getValue("COLUMN_NAME"),toList()))).forEach((table, columns) -> System.out.println(table + ": " + columns));

上面的示例产生以下输出:

FUNCTION_COLUMNS: [ALIAS_CATALOG, ALIAS_SCHEMA, ...]
CONSTANTS: [CONSTANT_CATALOG, CONSTANT_SCHEMA, ...]
SEQUENCES: [SEQUENCE_CATALOG, SEQUENCE_SCHEMA, ...]

它是如何工作的? 让我们逐步进行

DSL.using(c).fetch(sql)// Here, we transform a List into a Stream.stream()// We're collecting Stream elements into a new
// collection type.collect(// The Collector is a grouping operation, producing
// a MapgroupingBy(// The grouping operation's group key is defined by
// the jOOQ Record's TABLE_NAME valuer -> r.getValue("TABLE_NAME"),// The grouping operation's group value is generated
// by this mapping expression...mapping(// ... which is essentially mapping each grouped
// jOOQ Record to the Record's COLUMN_NAME valuer -> r.getValue("COLUMN_NAME"),// ... and then collecting all those values into a
// java.util.List. WhewtoList())))// Once we have this List<String, List<String>> we
// can simply consume it with the following Consumer
// lambda expression.forEach((table, columns) -> System.out.println(table + ": " + columns));

得到它了? 第一次玩这些东西时,肯定有些棘手。 起初,新类​​型,泛型泛型,lambda表达式的组合可能会有些混乱。 最好的办法就是简单地练习这些东西,直到您掌握了它。 毕竟,与以前的Java Collections API相比,整个Streams API确实是一场革命。

好消息是:此API是最终的,并将保留。 练习每一分钟都是对自己未来的投资。

请注意,以上程序使用了以下静态导入:

import static java.util.stream.Collectors.*;

还要注意,不再像数据库中那样对输出进行排序。 这是因为groupingBy收集器返回java.util.HashMap 。 在我们的例子中,我们可能更喜欢将东西收集到java.util.LinkedHashMap ,该对象保留插入/收集的顺序:

DSL.using(c).fetch(sql).stream().collect(groupingBy(r -> r.getValue("TABLE_NAME"),// Add this Supplier to the groupingBy// method callLinkedHashMap::new,mapping(r -> r.getValue("COLUMN_NAME"),toList()))).forEach(...);

我们可以继续使用其他转换结果的方法。 想象一下,我们想根据上述模式生成简单的DDL。 非常简单 首先,我们需要选择列的数据类型。 我们将其简单地添加到我们的SQL查询中:

String sql ="select " +"table_name, " +"column_name, " +"type_name " + // Add the column type"from information_schema.columns " +"order by " +"table_catalog, " +"table_schema, " +"table_name, " +"ordinal_position";

我还为示例引入了一个新的本地类,以包装名称和类型属性:

class Column {final String name;final String type;Column(String name, String type) {this.name = name;this.type = type;}
}

现在,让我们看看如何更改Streams API方法调用:

result.stream().collect(groupingBy(r -> r.getValue("TABLE_NAME"),LinkedHashMap::new,mapping(// We now collect this new wrapper type// instead of just the COLUMN_NAMEr -> new Column(r.getValue("COLUMN_NAME", String.class),r.getValue("TYPE_NAME", String.class)),toList()))).forEach((table, columns) -> {// Just emit a CREATE TABLE statementSystem.out.println("CREATE TABLE " + table + " (");// Map each "Column" type into a String// containing the column specification,// and join them using comma and// newline. Done!System.out.println(columns.stream().map(col -> "  " + col.name +" " + col.type).collect(Collectors.joining(",\n")));System.out.println(");");});

输出再好不过了!

CREATE TABLE CATALOGS(CATALOG_NAME VARCHAR
);
CREATE TABLE COLLATIONS(NAME VARCHAR,KEY VARCHAR
);
CREATE TABLE COLUMNS(TABLE_CATALOG VARCHAR,TABLE_SCHEMA VARCHAR,TABLE_NAME VARCHAR,COLUMN_NAME VARCHAR,ORDINAL_POSITION INTEGER,COLUMN_DEFAULT VARCHAR,IS_NULLABLE VARCHAR,DATA_TYPE INTEGER,CHARACTER_MAXIMUM_LENGTH INTEGER,CHARACTER_OCTET_LENGTH INTEGER,NUMERIC_PRECISION INTEGER,NUMERIC_PRECISION_RADIX INTEGER,NUMERIC_SCALE INTEGER,CHARACTER_SET_NAME VARCHAR,COLLATION_NAME VARCHAR,TYPE_NAME VARCHAR,NULLABLE INTEGER,IS_COMPUTED BOOLEAN,SELECTIVITY INTEGER,CHECK_CONSTRAINT VARCHAR,SEQUENCE_NAME VARCHAR,REMARKS VARCHAR,SOURCE_DATA_TYPE SMALLINT
);

ORM时代可能刚刚结束

这是一个强有力的声明。 ORM时代可能已经结束。 为什么? 因为使用函数表达式转换数据集是软件工程中最强大的概念之一。 函数式编程非常有表现力,也非常通用。 它是数据和数据流处理的核心。 我们的Java开发人员已经知道现有的功能语言。 例如,每个人以前都使用过SQL。 想一想。 使用SQL,您可以声明表源,将它们投影/转换为新的元组流,并将它们作为派生表提供给其他更高级的SQL语句或Java程序。

如果使用XML,则可以使用XSLT声明XML转换,并使用XProc pipelining将结果馈送到其他XML处理实体,例如另一个XSL样式表。

Java 8的Streams没什么。 使用SQL和Streams API是最强大的数据处理概念之一。 如果将jOOQ添加到堆栈,则可以从对数据库记录和查询API的类型安全访问中受益。 想象一下使用jOOQ的流畅API而不是使用SQL字符串编写上一条语句。

jooq-在Java中编写SQL的最佳方法

整个方法链可以是一个单一的流利数据转换链,如下所示:

DSL.using(c).select(COLUMNS.TABLE_NAME,COLUMNS.COLUMN_NAME,COLUMNS.TYPE_NAME).from(COLUMNS).orderBy(COLUMNS.TABLE_CATALOG,COLUMNS.TABLE_SCHEMA,COLUMNS.TABLE_NAME,COLUMNS.ORDINAL_POSITION).fetch()  // jOOQ ends here.stream() // Streams start here.collect(groupingBy(r -> r.getValue(COLUMNS.TABLE_NAME),LinkedHashMap::new,mapping(r -> new Column(r.getValue(COLUMNS.COLUMN_NAME),r.getValue(COLUMNS.TYPE_NAME)),toList()))).forEach((table, columns) -> {// Just emit a CREATE TABLE statementSystem.out.println("CREATE TABLE " + table + " (");// Map each "Column" type into a String// containing the column specification,// and join them using comma and// newline. Done!System.out.println(columns.stream().map(col -> "  " + col.name +" " + col.type).collect(Collectors.joining(",\n")));System.out.println(");");});

Java 8是未来,借助jOOQ,Java 8和Streams API,您可以编写功能强大的数据转换API。 希望我们让您像我们一样兴奋! 请继续关注此博客上更多精彩的Java 8内容。

翻译自: https://www.javacodegeeks.com/2014/04/java-8-friday-no-more-need-for-orms.html

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/364485.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Pwn相关工具安装

$apt-get update $apt-get install python2.7 python-pip python-dev git libssl-dev libffi-dev build-essential $pip install --upgrade pip $sudo pip install pwntools sudo apt-get install nasm,gcc,gdb,binutils,hexedit #32位libc库 sudo apt-get install lib…

c 语言输出指针的值,C 语言指针

C 语言指针在本教程中&#xff0c;您将学习指针。什么是指针&#xff0c;如何使用它们以及在示例的帮助下使用它们时可能遇到的常见错误。指针是 C和C 编程的强大功能。在学习指针之前&#xff0c;让我们学习一下C语言编程中的地址。C 语言地址如果程序中有变量var&#xff0c…

Rabbitmq - 配置

目录 RabbitMQ 配置简介环境变量配置文件运行时参数和策略RabbitMQ 配置 简介 默认配置&#xff0c;已经可以有效地运行RabbitMQ&#xff0c;并且在大多数情况下不需要更改配置。不过为了在生产环境中稳定、高效的运行&#xff0c;RabbitMQ提供了三种方式来定制化服务 环境变量…

Java EE CDI限定词:快速浏览

在上下文和依赖注入&#xff08;CDI&#xff09;中&#xff0c; 限定符是类型安全和松散耦合的主体。 为什么&#xff1f; 没有CDI&#xff0c;我们将以类似于下面的方式注入Java EE组件 注意&#xff1a;这实际上不会编译&#xff0c;只是假设的代码片段 例子1 例子2 上述…

Windows 系统光盘刻录教程-光盘怎样刻录?刻录数据光盘用轨道一次写入还是光盘一次写入?...

刻录光盘需要 DVD-RW 的光驱&#xff0c;并且光盘需要 DVD-R 的光盘用于刻录。刻录工具可以使用 https://cn.ultraiso.net/ 来进行刻录。选择软件目录 中 工具 &#xff0c;选择 刻录光盘映像 即可进行配置&#xff1a; 此时涉及到了光盘写入的方式的选择问题&#xff0c;在网上…

webpack编译时No PostCSS Config的解决方法

1. {loader:"postcss-loader",options: { // 如果没有options这个选项将会报错 No PostCSS Config foundplugins: (loader) > [require(autoprefixer)(), //CSS浏览器兼容]}}2.在项目根目录新建 postcss.config.js文件&#xff0c;并对 postcss进行配置…

c语言库文件是dll还是lib,C语言之静态链接库与动态链接库(2)

我们发现&#xff0c;无论是静态链接库还是动态链接库&#xff0c;最后都有lib文件&#xff0c;那么两者区别是什么呢&#xff1f;其实&#xff0c;两个是完全不一样的东西。静态库对应的lib文件叫静态库&#xff0c;动态库对应的lib文件叫导入库。实际上静态库本身就包含了实际…

NTC3950-10K温度传感器

一、计算公式 补充&#xff1a; B3950 R10K T225度 查RT表&#xff0c;25度对应的是10K 电路&#xff1a;   热敏电阻与上拉电阻R813分压&#xff0c;获取温度与Vo电压的关系&#xff0c;在根据Vo折算出与MCU ADC的数值。 再将ADC代出Rt&#xff0c;即得到ADC与T的关系公式。…

使不安全变得更加安全

总览 如果直接使用Unsafe&#xff0c;则可能会导致JVM崩溃。 当您访问尚未映射的内存页面并且在Unix上的结果是SIGSEG&#xff08;如果您访问页面0&#xff09;或SIGBUS&#xff08;如果您访问另一个未映射的页面&#xff09;时&#xff0c;就会发生这种情况。 使用MethodHand…

二分搜索树的基本实现

基本操作的动画演示 插入&#xff08;略&#xff09; 搜索&#xff08;略&#xff09; 删除节点 代码 package com.yunche.datastructure;import java.util.LinkedList; import java.util.Queue;/*** ClassName: BST* Description: 二叉搜索树&#xff1a;每个节点的左子树的值…

js ||

||或位符号 a || b 1.当a ,b 均为true时&#xff0c;return a 2.当 a,b均为false时&#xff0c;return b 3.当a,b为一false一true,return true的那个值 && 与位符号 a&&b 1.当a,b均为true时&#xff0c;return b 2.当&#xff0c;b均为false时&#xff…

计算机c语言二级题型,计算机二级C语言题型和评分标准

该楼层疑似违规已被系统折叠 隐藏此楼查看此楼全国计算机二级考试大题把题目给定程序删除了&#xff0c;正确运行&#xff0c;这样会不会给分&#xff1f;50、请编写函数fun, 函数的功能是: 将M行N列的二维数组中的数据, 按列的顺序依次放到一维数组中。函数fun中给出的语句仅供…

什么是Mockito Extra接口?

如果要编写轻量级的JUnit测试&#xff0c; Mockito是我最喜欢的小帮手。 如有必要&#xff0c;可以通过模拟轻松地替换被测单元的“实际”依赖关系&#xff0c;这非常有用。 尤其是在处理框架API的边界线时&#xff0c;此类依赖项的设置否则可能非常昂贵。 但是有时候情况要复…

d9900 修改ip 思科dcm_思科设备SSH登陆详细配置过程

思科设备SSH登陆详细配置过程我们用GNS3进行拓扑搭建。实验拓扑图如下&#xff1a;进行完基本配置之后开始配置SSH服务器(R2)1.首先验证设备是否支持SSHR2#show ip ssh能够识别这条命令就说明支持。2.配置IP域名。使用config# ip domain-name domain-name全局配置模式命令配置网…

scrapy框架使用splash渲染引擎爬取动态页面

1.启动docker&#xff0c;在命令行里输入 docker run -p 8050:8050 scrapinghub/splash在docker上运行splash引擎 2.接下来就可以来写爬虫文件了 首先在setting里配置 splash_urlhttp://loaclhost:8050 DUPEFLITERscrapy_splash.SplashAwareDupeFilterDOWNLOADER_MIDDLEWARES …

Testing BlogJet

I have installed an interesting application - BlogJet. Its a cool Windows client for my blog tool (as well as for other tools). Get your copy here: http://blogjet.com"Computers are useless. They can only give you answers." -- Pablo Picasso转载于:…

async,await

function timeout(ms){return new Promise(function(resolve){setTimeout(resolve,ms)}) }async function asyncPrint(value,ms){await timeout(ms);console.log(value) } asyncPrint(hello world,5000) 这段代码是过了5秒再显示hello world await是要等待这句代码执行完&…

Homebrew是什么?怎么关闭自动更新?

Homebrew是MacOS 的软件包管理器。 通过它可以安装、卸载、更新、查看、搜索任何想要安装的软件。如&#xff1a;git, node等。 安装Homebrew /usr/bin/ruby -e "$(curl -fsSL https://raw.githubusercontent.com/Homebrew/install/master/install)" 查看Homebrew br…

C语言中case后面有空格吗,C语言中switch case语句可变参实现方法(case 参数 空格...空格 参数 :)...

正常情况下&#xff0c;switch case语句是这么写的&#xff1a;switch(参数){case1:...;break;case2:...;break;default:...break;}这种是我们最常见的写法&#xff0c;当然也可以这么写&#xff1a;switch(参数){case1:case2:case3:case4:...;break;default:...;break;}接下来…

java 把string转为keyevent_盘点现在Java强大第三方库(字符串操作),程序员都该知道!...

1.字符串与集合间的转化引用第三方库 Apache Commons Lang jre连接值得一提的自JDK1.8以后字符串集合转为字符串可以使用String类下的join()方法,但别的数据类型还是要依靠第三方库--对比JDK和第三库代码如下我自己是一名从事了多年开发的java老程序员&#xff0c;这段时间整理…