diff --git a/lib/active_record/connection_adapters/amazon_timestream/database_statements.rb b/lib/active_record/connection_adapters/amazon_timestream/database_statements.rb
index f667352..bf9ae8e 100644
--- a/lib/active_record/connection_adapters/amazon_timestream/database_statements.rb
+++ b/lib/active_record/connection_adapters/amazon_timestream/database_statements.rb
@@ -8,7 +8,7 @@ module AmazonTimestream
       module DatabaseStatements
         def execute(sql, name = nil)
           log(sql, name) do
-            @connection.query({ query_string: sql })
+            @connection.query query_string: sql
           end
         end
 
diff --git a/lib/active_record/connection_adapters/amazon_timestream/schema_statements.rb b/lib/active_record/connection_adapters/amazon_timestream/schema_statements.rb
index 6a7b61a..3e910b4 100644
--- a/lib/active_record/connection_adapters/amazon_timestream/schema_statements.rb
+++ b/lib/active_record/connection_adapters/amazon_timestream/schema_statements.rb
@@ -7,14 +7,14 @@ module ConnectionAdapters
     module AmazonTimestream
       module SchemaStatements
         def tables(_name = nil)
-          response = @connection.query({ query_string: "SHOW TABLES FROM \"#{@database}\"" })
+          response = @connection.query query_string: "SHOW TABLES FROM \"#{@database}\""
           response.rows.map { |r| r.data[0].scalar_value }
         end
 
         def columns(table_name, _name = nil)
-          response = @connection.query({ query_string: "DESCRIBE \"#{@database}\".\"#{table_name}\"" })
+          response = @connection.query query_string: "DESCRIBE \"#{@database}\".\"#{table_name}\""
           response.rows.map do |r|
-            AmazonTimestreamColumn.new r.data[0].scalar_value, nil, lookup_cast_type(r.data[1].scalar_value)
+            AmazonTimestreamColumn.new r.data[0].scalar_value, nil, fetch_type_metadata(r.data[1].scalar_value)
           end
         end