diff --git a/lib/exqlite/connection.ex b/lib/exqlite/connection.ex
new file mode 100644
index 00000000..1258014e
--- /dev/null
+++ b/lib/exqlite/connection.ex
@@ -0,0 +1,140 @@
+defmodule Exqlite.Connection do
+
+  @doc """
+  This module imlements connection details as defined in DBProtocol.
+
+  Notes:
+    - we try to closely follow structure and naming convention of myxql.
+    - sqlite thrives when there are many small conventions, so we may not implement
+      some strategies employed by other adapters. See https://sqlite.org/np1queryprob.html
+  """
+
+  use DBConnection
+  alias Exqlite.Sqlite3
+  alias Exqlite.Error
+  alias Exqlite.Result
+
+  defstruct [
+    :db
+  ]
+
+  @impl true
+  def connect(opts) do
+    path = Keyword.get(opts, :path)
+
+    case path do
+      nil ->
+        {:error,
+         %Error{
+           message:
+             "You must provide a :path to the database. Example: connect(path: \"./\") or connect(path: :memory)"
+         }}
+
+      _ ->
+        do_connect(path)
+    end
+  end
+
+  @impl true
+  def disconnect(_reason, %__MODULE__{db: db}) do
+    case Sqlite3.close(db) do
+      :ok -> :ok
+      {:error, reason} -> {:error, %Error{message: reason}}
+    end
+  end
+
+  @impl true
+  def checkin(state) do
+    {:ok, state}
+  end
+
+  @impl true
+  def checkout(state) do
+    {:ok, state}
+  end
+
+  ###----------------------------------
+  #   handle_* implementations
+  ###----------------------------------
+
+  @impl true
+  def handle_prepare(query, _opts, state) do
+    # TODO: we may want to cache prepared queries like Myxql does
+    #       for now we just invoke sqlite directly
+    case Sqlite3.prepare(state.db, query) do
+      {:ok, statement} -> {:ok, statement, state}
+      {:error, reason} -> %Error{message: reason}
+    end
+  end
+
+  @doc """
+  Begin a transaction.
+
+  For full info refer to sqlite docs: https://sqlite.org/lang_transaction.html
+
+  Note: default transaction mode is DEFERRED.
+  """
+  @impl true
+  def handle_begin(opts, state) do
+    # TODO: track nested transactions.
+    #       sqlite doesn't nest transactions with BEGIN... COMMIT...,
+    #       use the SAVEPOINT and RELEASE commands.
+
+    # TODO: handle/track SAVEPOINT
+    case Keyword.get(opts, :mode, :deferred) do
+      :immediate -> handle_transaction(:begin, "BEGIN IMMEDIATE TRANSACTION", state)
+      :exclusive -> handle_transaction(:begin, "BEGIN EXCLUSIVE TRANSACTION", state)
+      mode when mode in [nil, :deferred] -> handle_transaction(:begin, "BEGIN TRANSACTION", state)
+    end
+  end
+
+  @impl true
+  def handle_commit(_opts, state) do
+    # TODO: once we handle SAVEPOINT, we need to handle RELEASE
+    #       COMMIT TO
+    #       Meanwhile we just COMMIT
+    #       see https://sqlite.org/lang_transaction.html
+    handle_transaction(:commit, "COMMIT", state)
+  end
+
+  @impl true
+  def handle_rollback(_opts, state) do
+    # TODO: once we handle SAVEPOINT, we need to handle ROLLBACK TO
+    #       Meanwhile we just ROLLBACK
+    #       see https://sqlite.org/lang_transaction.html
+    handle_transaction(:rollback, "ROLLBACK", state)
+  end
+
+  ###----------------------------------
+  #     Internal functions and helpers
+  ###----------------------------------
+
+  defp do_connect(path) do
+    case Sqlite3.open(path) do
+      {:ok, db} ->
+        state = %__MODULE__{
+          db: db
+        }
+
+        {:ok, state}
+
+      {:error, reason} ->
+        {:error, %Exqlite.Error{message: reason}}
+    end
+  end
+
+  defp handle_transaction(call, statement, state) do
+    case Sqlite3.execute(state.db, statement) do
+      :ok ->
+        result = %Result{
+          command: call
+        }
+
+        # TODO: if we track transactions, update state here
+        {:ok, statement, result, state}
+
+      {:error, {code, reason}} ->
+        {:error, %Error{message: "#{reason}. Code: #{code}"}}
+    end
+  end
+end
diff --git a/lib/exqlite/sqlite3_nif.ex b/lib/exqlite/sqlite3_nif.ex
index 6612cf70..07d0042b 100644
--- a/lib/exqlite/sqlite3_nif.ex
+++ b/lib/exqlite/sqlite3_nif.ex
@@ -21,7 +21,7 @@ defmodule Exqlite.Sqlite3NIF do
   @spec close(db()) :: :ok | {:error, reason()}
   def close(_conn), do: :erlang.nif_error(:not_loaded)
 
-  @spec execute(db(), String.Chars.t()) :: {:ok, any} | {:error, reason()}
+  @spec execute(db(), String.Chars.t()) :: :ok | {:error, reason()}
   def execute(_conn, _sql), do: :erlang.nif_error(:not_loaded)
 
   @spec changes(db()) :: {:ok, integer()}