Providing a execute method on a specific connection.

007lva · Jun 24, 2018 · ec3f645 · ec3f645
1 parent 9c45705
commit ec3f645
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/src/clear/sql/sql.cr b/src/clear/sql/sql.cr
@@ -161,6 +161,14 @@ module Clear
       log_query(sql) { Clear::SQL.connection("default").exec(sql) }
     end
 
+    # Execute a SQL request on a specific connection.
+    #
+    # Usage:
+    # Clear::SQL.execute("seconddatabase", "SELECT 1 FROM users")
+    def execute(connection : Symbolic, sql)
+      log_query(sql) { Clear::SQL.connection(connection).exec(sql) }
+    end
+
     # :nodoc:
     def sel_str(s : Selectable)
       s.is_a?(Symbolic) ? s.to_s : s.to_sql