2 files changed, 48 insertions, 0 deletions
diff --git a/activerecord/lib/active_record/type_caster/connection.rb b/activerecord/lib/active_record/type_caster/connection.rb
new file mode 100644
index 0000000000..3878270770
--- /dev/null
+++ b/activerecord/lib/active_record/type_caster/connection.rb
@@ -0,0 +1,29 @@
+module ActiveRecord
+  module TypeCaster
+    class Connection
+      def initialize(klass, table_name)
+        @klass = klass
+        @table_name = table_name
+      end
+
+      def type_cast_for_database(attribute_name, value)
+        return value if value.is_a?(Arel::Nodes::BindParam)
+        column = column_for(attribute_name)
+        connection.type_cast_from_column(column, value)
+      end
+
+      protected
+
+      attr_reader :table_name
+      delegate :connection, to: :@klass
+
+      private
+
+      def column_for(attribute_name)
+        if connection.schema_cache.table_exists?(table_name)
+          connection.schema_cache.columns_hash(table_name)[attribute_name.to_s]
+        end
+      end
+    end
+  end
+end
diff --git a/activerecord/lib/active_record/type_caster/map.rb b/activerecord/lib/active_record/type_caster/map.rb
new file mode 100644
index 0000000000..4b1941351c
--- /dev/null
+++ b/activerecord/lib/active_record/type_caster/map.rb
@@ -0,0 +1,19 @@
+module ActiveRecord
+  module TypeCaster
+    class Map
+      def initialize(types)
+        @types = types
+      end
+
+      def type_cast_for_database(attr_name, value)
+        return value if value.is_a?(Arel::Nodes::BindParam)
+        type = types.type_for_attribute(attr_name.to_s)
+        type.serialize(value)
+      end
+
+      protected
+
+      attr_reader :types
+    end
+  end
+end