关于 Scala-Sql 库源码一处疑惑

背景

本文使用的 scala-sql 是一个轻量级的 scala jdbc 库,它是一个简单的JDBC的封装,以提供类型安全的、简洁的scala API。整体使用上非常方便快捷,不输 scala 专有的数据层 框架 slick、quill 等。

下面的问题是基本上是因为一个Scala类型系统上的一处问题而产生的,这个错连IDEA都无法判断了,然后编译确实能够通过的,充分说明 Scala 的类型系统的复杂性。

使用scala 进行 query 即 rows 操作时,比如下面这段

// Rows 的 case 类,主要用来接收数据库查询出来数据的实体
case class MetricsCustomer(
metricDate: String, orders: Int,customerId: Long,
appName: String,  companyName: String,  createTime: DateTime
)


val data = scalaSqlDB.rows[MetricsCustomer](sql)

rows 的核心代码如下:

def rows[T : ResultSetMapper](sql: SQLWithArgs): List[T] = withPreparedStatement(sql.sql) { prepared =>
    val buffer = new ListBuffer[T]()
    if (sql.args != null) setStatementArgs(prepared, sql.args)
 
    val rs = prepared.executeQuery()
    // val rsMeta = rs.getMetaData
    while (rs.next()) {
     //核心代码,得到上下文中ResultSetMapper类型的隐式值
      val mapped = implicitly[ResultSetMapper[T]].from(rs)
      buffer += mappedde

    }
    LOG.debug("SQL result: {}", buffer.size)
    buffer.toList
  }

重点看核心代码val mapped = implicitly[ResultSetMapper[T]].from(rs),得到上下文中ResultSetMappe类型的隐式值,找到的应该是如下这个结果:

object ResultSetMapper {
    implicit def material[T]: ResultSetMapper[T] = macro Macros.generateCaseClassResultSetMapper[T]
  }

这里进入到了 macro,调用macro方法 generateCaseClassResultSetMapper, 经过 macro 的一系列操作后,生成的 tree 如下(macro具体细节略)

{
  import wangzx.scala_commons.sql._;
  import java.sql.ResultSet;
  {
    final class $anon extends CaseClassResultSetMapper[com.maple.scala.scalasql.MetricsCustomer] {
      def <init>() = {
        super.<init>();
        ()
      };
      val metricDate = Field[String]("metricDate");
      val orders = Field[Int]("orders");
      val customerId = Field[Long]("customerId");
      val appName = Field[String]("appName");
      val companyName = Field[String]("companyName");
      val createTime = Field[org.joda.time.DateTime]("createTime");
      override def from(arg: ResultSet): com.maple.scala.scalasql.MetricsCustomer = {
        val rs = new ResultSetEx(arg);
        new com.maple.scala.scalasql.MetricsCustomer(metricDate(rs), orders(rs), customerId(rs), appName(rs), companyName(rs), createTime(rs))
      }
    };
    new $anon()
  }
}

Context Bounds

Scala 2.8 允许隐式参数的简写语法,称为 Context Bounds。 简而言之,一个类型参数为 A 的方法需要 M [A] 类型的隐式参数

定义一个 foo 函数,泛型为A,有一个隐式参数,接收的额是一个为 M[A] 的对象

def foo[A](implicit ma: M[A])

可以简写成

def foo[A: M]

Scala sql 中看到了 Field 的定义

case class Field[T: JdbcValueAccessor](name: String, default: Option[T] = None) {...}

trait JdbcValueAccessor[T] {
    def passIn(stmt: PreparedStatement, index: Int, value: T)
    def passOut(rs: ResultSet, index: Int): T
    def passOut(rs: ResultSet, name: String): T
}

等价于下面这种写法:

case class Field[T](implicit jdbc: JdbcValueAccessor[T])(name: String, default: Option[T] = None) 

JdbcValueAccessor[T] 已经有了各种数据库类型的实现类了,包括 String,Int,Double,Timestamp等等。

所以上述通过 macro的代码,我复制到idea后发现如下问题


微信图片_20190510193245.png

而看 Field的定义,下面的Field的定义中,T确实和ResultSetMapper的T 类型一致。

abstract class CaseClassResultSetMapper[T] extends ResultSetMapper[T] {

    // cammel case mapping support such as userId -> user_id, postURL -> post_url
    case class Field[T: JdbcValueAccessor](name: String, default: Option[T] = None) {
      
    }
  }

问题

那么我的问题是,这样如何将Field 所需要的 对象类型(本文中是我自己定义的MetricsCustomer类型),转换为每个Field 自己的 所属类型呢?比如 String,Int等,这里是如何做到的?

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成,浏览时请结合常识与多方信息审慎甄别。
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

友情链接更多精彩内容