1 files changed, 81 insertions, 0 deletions
diff --git a/src/FirebirdConnection.php b/src/FirebirdConnection.php
new file mode 100755
index 0000000..8128b18
--- /dev/null
+++ b/src/FirebirdConnection.php
@@ -0,0 +1,81 @@
+<?php
+
+namespace Xgrz\Firebird;
+
+use Illuminate\Database\Connection as DatabaseConnection;
+use Xgrz\Firebird\Query\Builder as FirebirdQueryBuilder;
+use Xgrz\Firebird\Query\Grammars\FirebirdGrammar as FirebirdQueryGrammar;
+use Xgrz\Firebird\Query\Processors\FirebirdProcessor as FirebirdQueryProcessor;
+use Xgrz\Firebird\Schema\Builder as FirebirdSchemaBuilder;
+use Xgrz\Firebird\Schema\Grammars\FirebirdGrammar as FirebirdSchemaGrammar;
+
+class FirebirdConnection extends DatabaseConnection
+{
+    /**
+     * Get the default query grammar instance.
+     *
+     * @return \Illuminate\Database\Query\Grammars\Grammar
+     */
+    protected function getDefaultQueryGrammar()
+    {
+        return new FirebirdQueryGrammar($this);
+    }
+
+    /**
+     * Get the default post processor instance.
+     *
+     * @return \Illuminate\Database\Query\Processors\Processor
+     */
+    protected function getDefaultPostProcessor()
+    {
+        return new FirebirdQueryProcessor;
+    }
+
+    /**
+     * Get a schema builder instance for this connection.
+     *
+     * @return \Firebird\Schema\Builder
+     */
+    public function getSchemaBuilder()
+    {
+        if (is_null($this->schemaGrammar)) {
+            $this->useDefaultSchemaGrammar();
+        }
+
+        return new FirebirdSchemaBuilder($this);
+    }
+
+    /**
+     * Get the default schema grammar instance.
+     *
+     * @return \Firebird\Schema\Grammars\FirebirdGrammar
+     */
+    protected function getDefaultSchemaGrammar()
+    {
+        return $this->withTablePrefix(new FirebirdSchemaGrammar);
+    }
+
+    /**
+     * Get a new query builder instance.
+     *
+     * @return \Firebird\Query\Builder
+     */
+    public function query()
+    {
+        return new FirebirdQueryBuilder(
+            $this, $this->getQueryGrammar(), $this->getPostProcessor()
+        );
+    }
+
+    /**
+     * Execute a stored procedure.
+     *
+     * @param  string  $procedure
+     * @param  array  $values
+     * @return \Illuminate\Support\Collection
+     */
+    public function executeProcedure($procedure, array $values = [])
+    {
+        return $this->query()->fromProcedure($procedure, $values)->get();
+    }
+}