first commit

Author: y-yoshinoya

.gitignore

@@ -0,0 +1,3 @@
+project/project
+project/target
+target

README.md

@@ -0,0 +1,3 @@
+# Scala ActiveRecord #
+
+Version 0.1

build.sbt

@@ -0,0 +1,25 @@
+sbtPlugin := true
+
+name := "scala-activerecord"
+
+version := "0.1-SNAPSHOT"
+
+organization := "com.github.aselab"
+
+libraryDependencies ++= Seq(
+  "org.squeryl" %% "squeryl" % "0.9.5-RC1",
+  "com.typesafe.config" % "config" % "0.3.0",
+  "org.specs2" %% "specs2" % "1.9" % "test",
+  "c3p0" % "c3p0" % "0.9.1.2",
+  "com.h2database" % "h2" % "1.3.157" % "test"
+)
+
+resolvers ++= Seq(
+  "Typesafe Repository" at "http://repo.typesafe.com/typesafe/releases/"
+)
+
+scalacOptions ++= Seq("-deprecation", "-unchecked")
+
+parallelExecution in Test := false
+
+fork in Test := false

project/build.properties

@@ -0,0 +1 @@
+sbt.version=0.11.2

src/main/java/com/github/aselab/activerecord/annotations/Ignore.java

@@ -0,0 +1,8 @@
+package com.github.aselab.activerecord.annotations;
+
+import java.lang.annotation.*;
+
+@Retention(RetentionPolicy.RUNTIME)
+@Target( { ElementType.FIELD })
+public @interface Ignore {
+}

src/main/java/com/github/aselab/activerecord/annotations/Unique.java

@@ -0,0 +1,8 @@
+package com.github.aselab.activerecord.annotations;
+
+import java.lang.annotation.*;
+
+@Retention(RetentionPolicy.RUNTIME)
+@Target( { ElementType.FIELD })
+public @interface Unique {
+}

src/main/scala/CRUDable.scala

@@ -0,0 +1,156 @@
+package com.github.aselab.activerecord
+
+import org.squeryl.annotations.Transient
+
+/**
+ * CRUDとコールバックのインタフェース
+ */
+trait CRUDable {
+  /** 新規インスタンスフラグ */
+  @Transient
+  protected var _isNewInstance = true
+
+  /** 新規インスタンスフラグ */
+  def isNewInstance = _isNewInstance
+
+  /**
+   * 保存メソッド．
+   *
+   * 新規インスタンスの時はdoCreateを，
+   * そうでなければdoUpdateを呼び出す．
+   * 保存前と保存後にコールバックメソッドを呼び出す．
+   */
+  def save(): Boolean = {
+    val onCreate = isNewInstance
+
+    if (onCreate) beforeCreate() else beforeUpdate()
+    beforeSave()
+
+    val result = if (isNewInstance) doCreate() else doUpdate()
+
+    if (result) {
+      if (onCreate) afterCreate() else afterUpdate()
+      afterSave()
+      _isNewInstance = false
+    }
+    result
+  }
+
+  /**
+   * 削除メソッド.
+   * 削除前と削除後にコールバックメソッドを呼び出す．
+   */
+  def delete(): Boolean = !isNewInstance && {
+    beforeDelete()
+
+    val result = doDelete()
+
+    if (result) {
+      afterDelete()
+      _isNewInstance = true
+    }
+    result
+  }
+
+  /**
+   * 新規保存処理を行うメソッド.
+   * 保存に成功した場合trueを，失敗した場合falseを返すように実装する．
+   */
+  protected def doCreate(): Boolean
+
+  /**
+   * 更新保存処理を行うメソッド.
+   * 更新に成功した場合trueを，失敗した場合falseを返すように実装する．
+   */
+  protected def doUpdate(): Boolean
+
+  /**
+   * 削除処理を行うメソッド.
+   * 削除に成功した場合trueを，失敗した場合falseを返すように実装する．
+   */
+  protected def doDelete(): Boolean
+
+  /**
+   * 保存前のコールバックメソッド.
+   * デフォルトでは何もしないため，必要があれば派生クラスで
+   * オーバーライドして実装する．
+   *
+   * saveメソッドが呼び出された時，実際の保存メソッドである
+   * doCreate, doUpdateを実行する前に呼びだされる．
+   */
+  protected def beforeSave() {}
+
+  /**
+   * 保存後のコールバックメソッド.
+   * デフォルトでは何もしないため，必要があれば派生クラスで
+   * オーバーライドして実装する．
+   *
+   * saveメソッドが呼び出された時，実際の保存メソッドである
+   * doCreate, doUpdateを実行した後に呼びだされる．
+   * 保存に失敗した場合は呼び出されない．
+   */
+  protected def afterSave() {}
+
+  /**
+   * 新規作成前のコールバックメソッド.
+   * デフォルトでは何もしないため，必要があれば派生クラスで
+   * オーバーライドして実装する．
+   *
+   * saveメソッドが呼び出された時，実際の保存メソッドである
+   * doCreateを実行する前に呼びだされる．
+   */
+  protected def beforeCreate() {}
+
+  /**
+   * 新規作成後のコールバックメソッド.
+   * デフォルトでは何もしないため，必要があれば派生クラスで
+   * オーバーライドして実装する．
+   *
+   * saveメソッドが呼び出された時，実際の保存メソッドである
+   * doCreateを実行した後に呼びだされる．
+   * 保存に失敗した場合は呼び出されない．
+   */
+  protected def afterCreate() {}
+
+  /**
+   * 更新前のコールバックメソッド.
+   * デフォルトでは何もしないため，必要があれば派生クラスで
+   * オーバーライドして実装する．
+   *
+   * saveメソッドが呼び出された時，実際の保存メソッドである
+   * doUpdateを実行する前に呼びだされる．
+   */
+  protected def beforeUpdate() {}
+
+  /**
+   * 更新後のコールバックメソッド.
+   * デフォルトでは何もしないため，必要があれば派生クラスで
+   * オーバーライドして実装する．
+   *
+   * saveメソッドが呼び出された時，実際の保存メソッドである
+   * doUpdateを実行した後に呼びだされる．
+   * 保存に失敗した場合は呼び出されない．
+   */
+  protected def afterUpdate() {}
+
+  /**
+   * 削除前のコールバックメソッド.
+   * デフォルトでは何もしないため，必要があれば派生クラスで
+   * オーバーライドして実装する．
+   *
+   * deleteメソッドが呼び出された時，実際の削除メソッドである
+   * doDeleteを実行する前に呼びだされる．
+   */
+  protected def beforeDelete() {}
+
+  /**
+   * 削除後のコールバックメソッド.
+   * デフォルトでは何もしないため，必要があれば派生クラスで
+   * オーバーライドして実装する．
+   *
+   * deleteメソッドが呼び出された時，実際の削除メソッドである
+   * doDeleteを実行した後に呼びだされる．
+   * 削除に失敗した場合は呼び出されない．
+   */
+  protected def afterDelete() {}
+}

src/main/scala/annotations.scala

@@ -0,0 +1,19 @@
+package com.github.aselab.activerecord
+
+import org.squeryl.annotations._
+
+/** アノテーション定義 */
+object Annotations {
+  import annotation.target._
+
+  /**
+   * 無視フィールドアノテーション.
+   * フォーム検証対象外のフィールドに付加する．
+   */
+  type Ignore = annotations.Ignore @field
+
+  /**
+   * ユニークアノテーション.
+   */
+  type Unique = annotations.Unique @field
+}

src/main/scala/reflections.scala

@@ -0,0 +1,104 @@
+package com.github.aselab.activerecord
+
+import java.lang.annotation.Annotation
+import java.lang.reflect.Field
+import annotations._
+
+/**
+ * フィールド情報モデル
+ * @param name フィールド名
+ * @param fieldType フィールドタイプ
+ * @param isOption Option型かどうか
+ * @param isSeq シーケンスかどうか
+ * @param annotations アノテーションリスト
+ */
+case class FieldInfo(
+  name: String, fieldType: Class[_],
+  isOption: Boolean, isSeq: Boolean,
+  annotations: Seq[Annotation] = Nil
+) {
+  private lazy val annotationMap = annotations.map {
+    a => (a.annotationType.getSimpleName, a)
+  }.toMap
+
+  /** Ignoreフィールドかどうか */
+  lazy val ignored = annotationMap.isDefinedAt("Ignore")
+  /** Uniqueフィールドかどうか */
+  lazy val unique = annotationMap.isDefinedAt("Unique")
+}
+
+/** フィールド情報オブジェクト */
+object FieldInfo {
+  def apply(name: String, value: Any, field: Option[Field]): FieldInfo = value match {
+    case Some(v) => apply(name, v, None).copy(isOption = true)
+    case None => throw ConventionException.optionValueMustBeSome
+
+    case l: Traversable[_] => l.toSeq match {
+      case Seq(v, _*) => apply(name, v, None).copy(isSeq = true)
+      case Nil => throw ConventionException.traversableValueMustNotBeNil
+    }
+
+    case v: Any => FieldInfo(name, v.getClass, false, false)
+    case v =>
+      val fieldType = field.map(_.getType).getOrElse(
+        throw ConventionException.cannotDetectType(v))
+      FieldInfo(name, fieldType, false, false)
+  }
+
+  def apply(name: String, value: Any): FieldInfo = apply(name, value, None)
+
+  def apply(field: Field, value: Any): FieldInfo =
+    apply(field.getName, value, Some(field)).copy(annotations = field.getAnnotations.toSeq)
+}
+
+/** リフレクション用ユーティリティ */
+trait ReflectionUtil {
+  /**
+   * クラスからコンパニオンオブジェクトを返す.
+   * @param className クラス名
+   */
+  def classToCompanion(className: String): Any = {
+    val cc = Class.forName(className + "$")
+    cc.getField("MODULE$").get(cc)
+  }
+
+  /**
+   * クラスからコンパニオンオブジェクトを返す.
+   * @param c クラス
+   */
+  def classToCompanion(c: Class[_]): Any = classToCompanion(c.getName)
+
+  /**
+   * クラスからコンパニオンオブジェクトを返す.
+   * @param c 任意のオブジェクト
+   */
+  def companionToClass(c: Any) = Class.forName(c.getClass.getName.dropRight(1))
+
+  /**
+   * 任意のオブジェクトのフィールド値をリフレクションで取得/変更できるようにする
+   * 暗黙変換メソッド.
+   */
+  implicit def toReflectable(o: Any) = new {
+    val c = o.getClass
+
+    /**
+     * 値を取得する.
+     * @param name フィールド名
+     */
+    def getValue[T](name: String) = c.getMethod(name).invoke(o).asInstanceOf[T]
+
+    /**
+     * 値を設定する.
+     * @param name フィールド名
+     * @param value 設定する値
+     */
+    def setValue(name: String, value: Any) = {
+      val f = c.getDeclaredField(name)
+      f.setAccessible(true)
+      f.set(o, value)
+    }
+  }
+}
+
+/** リフレクション用ユーティリティ */
+object ReflectionUtil extends ReflectionUtil