Returns a specification to start this module under a supervisor.

See Supervisor.

Executes a safe (parameterized) query on the DuckDB connection and fetches all results.

This function retrieves the database connection, prepares a statement with the given query, executes it with the provided parameters, and fetches all results.

Parameters

• {query, params} - A tuple containing the SQL query string and a list of parameters.

Returns

• results - If the query is successfully executed and results are fetched.
• {:error, reason} - If there's an error retrieving the connection, executing the query, or fetching results.

Examples

iex> PhoenixAnalytics.Repo.execute_fetch({"SELECT * FROM users WHERE age > ?", [25]})
[%{"name" => "John", "age" => 30}, %{"name" => "Jane", "age" => 28}]

Executes a safe (parameterized) query on the DuckDB connection.

This function retrieves the database connection, prepares a statement with the given query, and executes it with the provided parameters. This method is preferred over execute_unsafe/1 as it helps prevent SQL injection attacks.

Parameters

• {query, params} - A tuple containing the SQL query string and a list of parameters.

Returns

• {:ok, result} - If the query is successfully executed.
• {:error, reason} - If there's an error retrieving the connection or executing the query.

Examples

iex> PhoenixAnalytics.Repo.execute_safe({"SELECT * FROM users WHERE id = ?", [1]})
{:ok, %Duckdbex.Result{}}

Executes an unsafe query on the DuckDB connection.

This function retrieves the database connection and executes the given query without any parameter binding. It should be used with caution, as it may be vulnerable to SQL injection if used with user-supplied input.

Parameters

• query - A string containing the SQL query to be executed.

Returns

• {:ok, result} - If the query is successfully executed.
• {:error, reason} - If there's an error retrieving the connection or executing the query.

Examples

iex> PhoenixAnalytics.Repo.execute_unsafe("SELECT * FROM users")
{:ok, %Duckdbex.Result{}}

Retrieves the current DuckDB connection from the GenServer state.

This function sends a synchronous call to the GenServer to get the current database connection stored in its state.

Returns

• {:ok, connection} - If the connection is successfully retrieved.
• {:error, reason} - If there's an error retrieving the connection.

Examples

iex> PhoenixAnalytics.Repo.get_connection()
{:ok, %Duckdbex.Connection{}}

Creates and returns a new DuckDB read connection.

This function opens a new connection to the DuckDB database for read operations, allowing for increased read throughput by not relying on the GenServer state.

Returns

• {:ok, connection} - If a new connection is successfully created.
• {:error, reason} - If there's an error creating the connection.

Examples

iex> PhoenixAnalytics.Repo.get_read_connection()
{:ok, %Duckdbex.Connection{}}

Initializes the GenServer state with a DuckDB connection.

This function opens a DuckDB database connection using the path specified in the application configuration. If the connection is successfully established, it returns the initial state with the connection.

Returns

• {:ok, state} - If the database connection is successfully established.
• {:stop, reason} - If there's an error opening the database or creating a connection.

Notes

• If @db_path is nil, the application will fail to start. Ensure that a valid database path is configured in the application environment.

Inserts multiple RequestLog entries into the database using the DuckDB appender.

This function retrieves the database connection, creates an appender for the specified table, and adds multiple RequestLog entries to the table in a batch operation. This method is more efficient for inserting large amounts of data compared to individual inserts.

Parameters

• batch - A list of RequestLog.t() to be inserted into the table.

Returns

• {:ok, result} - If the batch insert is successful.
• {:error, reason} - If there's an error retrieving the connection or performing the batch insert.

Examples

iex> batch = [%RequestLog{method: "GET", path: "/home"}, %RequestLog{method: "POST", path: "/api"}]
iex> PhoenixAnalytics.Repo.insert_many(batch)
:ok

For performance testing, you can run ../priv/repo/seeds.exs locally.