首页
学习
活动
专区
圈层
工具
发布

FunDA(0)- Functional Data Access accessible to all

设计FunDA的想法就是希望那些惯用ORM(Object Relational Mapper)开发MIS系统的编程人员们能快速轻松地使用像Slick这样的FRM(Functional Relation...FunDA包括两项重大功能: 一、提供按行处理数据功能的支持:FRM最强大的功能之一就是能够实现Query的函数组合,然后产生SQL语句来对后台数据库进行操作,返回结果是一个集合。...MemoryRow -> DataStore转换则是把内存中record内容转换成SQL语句再发送给后台数据库处理。...大体的开发计划可以分成下面几个阶段: 一、scalaz-streams-fs2+slick:先直接绑定slick作为FRM部分与后台数据库发生关系、fs2作为在内存中数据流和运算管理工具来实现FunDA...通过freemonad的多种功能实现模式(separation of concern)来实现FunDA数据库具体操作与各种FRM、ORM的松散耦合(loose coupling),最终能同时支持slick

1.3K100

FunDA(1)- Query Result Row:强类型Query结果行

FunDA的特点之一是以数据流方式提供逐行数据操作支持。这项功能解决了FRM如Slick数据操作以SQL批次模式为主所产生的问题。...为了实现安全高效的数据行操作,我们必须把FRM产生的Query结果集转变成一种强类型的结果集,也就是可以字段名称进行操作的数据行类型结果集。...在前面的一篇讨论中我们介绍了通过Shape来改变Slick Query结果行类型。不过这样的转变方式需要编程人员对Slick有较深的了解。更重要的是这种方式太依赖Slick的内部功能了。...我们希望FunDA可以支持多种FRM,所以应当尽量避免与任何FRM的紧密耦合。看来从FRM的返回结果开始进行数据行类型格式转换是一种比较现实的选择。...一般来说我们还是可以假定任何FRM的使用者对于FRM的Query结果集类型是能理解的,因为他们的主要目的就是为了使用这个结果集。

1.2K90
  • 您找到你想要的搜索结果了吗?
    是的
    没有找到

    FunDA(12)- 示范:强类型数据源 - strong typed data sources

    FunDA设计的主要目的是解决FRM(Functional Relation Mapping)如Slick这样的批次型操作工具库数据源行间游动操作的缺失问题。...FRM产生的结果集就是一种静态集合,缺乏动态更新操作方式。...FunDA提出的解决方案是把FRM产生的静态集合转变成动态流(stream),流内元素代表数据行(data row),一个完整的数据流代表一连串的数据行。...我们将在下面几个章节进行FunDA功能的使用示范。     Slick运算Query返回的结果集合内的数据行类型一般是Tuple类型。因为无法使用字段名,是弱类型。...FDAUserTask函数中调用字段名: // now access fields in the strong typed resultset def showRecord: FDAUserTask

    1.2K100

    FunDA(2)- Streaming Data Operation:流式数据操作

    在上一集的讨论里我们介绍并实现了强类型返回结果行。使用强类型主要的目的是当我们把后端数据库SQL批次操作搬到内存里转变成数据流式按行操作时能更方便、准确、高效地选定数据字段。...一般来说完整的流式数据处理流程包括了从数据库中读取数据、根据读取的每行数据状态再对后台数据库进行更新,包括:插入新数据、更新、删除等。...=> QueryAction(DataRow) -> ActionRow => execAction(ActionRow) -> Database  如果我们还是以Slick为目标FRM,那么这个ActionRow...语句如下:  update a,b set a.status=b.status where a.id=b.id 那位哥们的问题是如何用Slick来实现对a表的更新,不能用sql"???"...这个问题用Slick Query还真的不太容易解决(能不能解决就不想费功夫去想了),这是因为FRM的SQL批次处理弱点。

    1.6K60

    浅谈Slick(1)- 基本功能描述

    Slick (Scala language-integrated connection kit)是scala的一个FRM(Functional Relational Mapper),即函数式的关系数据库编程工具库...Slick把数据库编程融入到scala编程中,编程人员可以不需要编写SQL代码。我把Slick官方网站上Slick3.1.1文档的Slick介绍章节中的一些描述和例子拿过来帮助介绍Slick的功能。...Slick把Query编写与scala语言集成,这使编程人员可以用熟悉惯用的scala来表述SQL Query,直接的好处是scalac在编译时就能够发现Query错误: 1 //coffees.map...具体实现方式是利用freemonad(DBIOAction类型就是个freemonad)的延迟运算模式,将DBIOAction的编程和实际运算分离,在DBIOAction编程过程中不会产生副作用(side-effect...SQL语句:Slick提供了Plain SQL API, 如下: 1 val limit = 10.0 2 sql"select COF_NAME from COFFEES where PRICE <

    1.1K70

    Akka(27): Stream:Use case-Connecting Slick-dbStream & Scalaz-stream-fs2

    在以前的博文中我们介绍了Slick,它是一种FRM(Functional Relation Mapper)。...有别于ORM,FRM的特点是函数式的语法可以支持灵活的对象组合(Query Composition)实现大规模的代码重复利用,但同时这些特点又影响了编程人员群体对FRM的接受程度,阻碍了FRM成为广为流行的一种数据库编程方式...所以我们只能从小众心态来探讨如何改善Slick现状,希望通过与某些Stream库集成,在Slick FRM的基础上恢复一些人们熟悉的Recordset数据库光标(cursor)操作方式,希望如此可以降低...FRM数据库编程对函数式编程水平要求,能够吸引更多的编程人员接受FRM。...Slick和Akka-Stream可以说是自然匹配的一对,它们都是同一个公司产品,都支持Reactive-Specification。

    1.1K50

    FunDA:一个开源的函数式数据处理工具库,也是Slick的补充

    目前市面上FRM(Functional Relational Mapper),即函数式的数据库处理工具库的选择并不多,Typesafe公司的Slick可能是最通用的选择了。...整体上来说:Slick还是一个不错的函数式数据库编程工具,用scala语言,很多地方引用了函数式的抽象模式和对象(functional abstractions and objects)。...但是,FRM是一种偏重数据读取(data access)的开发模式,骨子里是一种批次运算模式,缺少了数据处理(data processing)所惯用的recordset逐行处理方式。...对于那些习惯了使用ORM(Object Relational Mapper)的资深数据库软件编程人员来说,这几乎是他们在大型复杂数据库软件开发项目中无法使用Slick的致命弱点。...FunDA在Slick功能的基础上增加了recordset数据集逐行处理功能,让使用者感觉亲切,能更灵活自然的在前台内存里实现强大的数据处理功能。

    77060

    细谈Slick(5)- 学习体会和将来实际应用的一些想法

    首先谈谈Slick的特点:主体方面Slick为函数式编程模式带来了SQL编程,可以把数据库表当作scala语言中的集合来对待。...倒是Query的函数组件如filter,take,drop,sortBy,groupBy等在函数式编程中还是比较适用的。...这样看来Slick的工作原理大体上是:    构建Query >>> 组合Query >>> 产生SQL语句 >>> 按流程把SQL语句发给数据库进行运算 >>> 获取结果 完成了上面的叙述后,总觉着好像缺少些什么...综合以上分析,如果从一个有多年信息管理系统(MIS)开发经验的程序员需求出发,能在工作中使用FRM是一种崭新的体验。与习惯用的ORM比较,从scala编程表达形式和程序运算方式上都有较大的改善。...希望无论在开发过程中或者将来的使用中都能得到有共同志愿朋友的参与和帮助。

    1.6K80

    没有“now”-分布式系统中的同时性问题

    没有“now”-分布式系统中的同时性问题 There is No Now Problems with simultaneity in distributed systems -Justin Sheehy...“Now.”...考虑到这些延迟,很难解释“now”在计算机系统中的确切含义。 不过,如果我们提前详细计划,理论上没有什么能组织我们对“now”达成共识。(相对论在这里不是问题,尽管它很容易让人分心。...因此我,任何地方的系统都应该能够就“now”达成一致,并共享对时间进程的共同、单一的看法。然后,网络和计算中的所有困难问题都将变得容易得多。...他需要勇敢和迷人的选择,直接面对它,明确不确定性,而不是假装“now”的一个绝对值再一个工作的分布式系统中是有意义的。 再Spanner的生产环境中,时钟延迟在任何时刻通常为1-7ms。

    56710

    SDP(3):ScalikeJDBC- JDBC-Engine:Fetching

    ScalikeJDBC在覆盖JDBC基本功能上是比较完整的,而且实现这些功能的方式比较简洁,运算效率方面自然会稍高一筹了。...一般来说,各种JDBC工具库如ORM,FRM软件通过各自的DSL在复杂的数据库表关系环境内进行数据管理编程,最终产生相关的SQL语句即(prepared)statement+parameters传递给指定类型的数据库...如果这样描述,那么JDBC-Engine主要的功能就是支持下面这个函数: jdbcRunSQL(context: JDBCContext): JDBCResultSet 这个函数的用户提供一个JDBCContext...类型值,然后由jdbcRunSQL进行接下来的运算并返回结果。...这几个参数都针对当前运算的SQL 3、Query参数:     Query类型:select/execute/update、单条/成批、前置/后置query、generateKey     SQL语句:

    1.9K50

    SQL中的DBLINK

    DBLINK的定义 当我们要跨本地数据库,访问另外一个数据库表中的数据时,本地数据库中就必须要创建远程数据库的DBLINK,通过DBLINK本地数据库可以像访问本地数据库一样访问远程数据库表中的数据。...QAZ1234' Go 执行完后我们会看到在SSMS的服务器对象下面有一个创建好的DBLINK连接,如下图: DBLINK的作用 前面的定义已经说明,通过DBLINK本地数据库可以像访问本地数据库一样访问远程数据库表中的数据...DBLINK示例 以本地Customers表和远程数据库192.168.0.39里SQL_Road数据库下的Orders表为例 Customers表 远程数据库中的Orders表 我们想用本地的Customers...表关联远程数据库192.168.0.39里SQL_Road数据库下的Orders表里的数据,可以这样写SQL: SELECT c.姓名,o.订单日期 FROM Customers c JOIN [192.168.0.38...].SQL_Road.dbo.Orders o ON c.客户ID=o.客户ID 结果如下: 这样我们就将本来隔绝的两个表通过DBLINK关联上了。

    43910

    SQL中的WITH...AS

    在SQL中的AS重命名与ORDER BY排序中我们知道,在SQL中可以利用AS对字段进行重命名,让查询结果更加清晰明了。...而在我们学习了SQL中的基本查询语句后,我们也会开始写稍微复杂一些的SQL语句来查询与分析数据。...而在很多时候并不是所有的数据信息查询可以简单的只用一条SQL语句来完成,这其中最常见的就是嵌套查询,也就是在一个查询结果的基础上再进一步查询想要的信息。...利用WITH...AS我们可以首先把SQL中的查询结果存储在一个临时的数据表中,从而可以继续在这个数据表中更一步的查询数据。...WITH...AS使用WITH...AS的SQL查询语句一般有如下结构:WITH 临时数据表 AS(SELECT...)SELECT...下面我们对常用的Customers数据表稍作修改: 在这个表中增加客户的订单数量

    35110

    SQL必知必会:SQL 中的连接

    连接 大家一定用过 LEFT JOIN、RIGHT JOIN 这样的操作符,这实际上就是连接,SQL 中的连接是多表操作的基础之一,对连接不了解很难去查询好多表。...本文是基于 SQL 99 标准中的连接查询,还有其他 SQL 标准,有些语句并不适用其他 SQL 标准。...交叉连接 交叉连接 SQL99 采用的是 CROSS JOIN,常听听说的笛卡尔乘积其实是 SQL92 中的,而交叉连接实际上就是 SQL92 中的笛卡尔乘积,也就是说 交叉连接 == 笛卡尔乘积。...select * from t1 CROSS JOIN t2 CROSS JOIN T3 自然连接 自然连接则是 SQL92 标准中的等值连接,自然连接是一种关联查询方式,它不需要使用 ON 子句指定连接条件...t2.field AND t2.field 一般来说在 SQL99 中,我们需要连接的表会采用 JOIN 进行连接,ON 指定了连接条件,后面可以是等值连接,也可以采用非等值连接。

    1.1K20

    sql中decode的用法_sql求和函数

    decode() 函数的语法: 1 Select decode(columnname,值1,翻译值1,值2,翻译值2,...值n,翻译值n,缺省值) 2 3 From talbename 4...5 Where … 其中:columnname为要选择的table中所定义的column;    缺省值可以是你要选择的column name本身,也可以是你想定义的其他值,比如Other等; 主要作用...) sale from output 若只与一个值进行比较: Select monthid ,decode(sale, NULL,‘---’,sale) sale from output decode中可使用其他函数...SELECT NAME,NVL(TO_CHAR(COMM),'NOT APPLICATION') FROM TABLE1; 如果用到decode函数中: select monthid,decode(nvl...(sale,6000),6000,'NG','OK') from output;   sign()函数根据某个值是0、正数还是负数,分别返回0、1、-1, 用如下的SQL语句取较小值: select monthid

    2.3K40

    SQL中的递归查询

    递归查询原理 SQL Server中的递归查询是通过CTE(表表达式)来实现。...在逻辑上可以将CTE名称的内部应用理解为前一个查询的结果集。 递归查询的终止条件 递归查询没有显式的递归终止条件,只有当第二个递归查询返回空结果集或是超出了递归次数的最大限制时才停止递归。...USE SQL_Road GO CREATE TABLE Company ( 部门ID INT, 父级ID INT, 部门名称 VARCHAR(10) ) INSERT...在查询语句中调用中CTE,而查询语句就是CTE的组成部分,即 “自己调用自己”,这就是递归的真谛所在。...具体结果如下: 以上就是递归查询的一些知识介绍了,自己可以动手实验一下,这个一般在面试中也经常会考察面试者,希望能帮助到大家~

    2.7K11
    领券