Skip to content

Commit b0f7332

Browse files
committed
add testfiles
1 parent d302608 commit b0f7332

29 files changed

+398
-0
lines changed
Lines changed: 17 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,17 @@
1+
# Example from docs/usage/drivers_and_querying.rst - code-block 1
2+
# Typical driver usage
3+
from sqlspec import SQLSpec
4+
from sqlspec.adapters.asyncpg import AsyncpgConfig
5+
6+
async def example():
7+
spec = SQLSpec()
8+
db = spec.add_config(AsyncpgConfig(pool_config={}))
9+
10+
async with spec.provide_session(db) as session:
11+
result = await session.execute("SELECT 1")
12+
print(result)
13+
14+
if __name__ == "__main__":
15+
import asyncio
16+
asyncio.run(example())
17+
Lines changed: 14 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,14 @@
1+
# Example from docs/usage/drivers_and_querying.rst - code-block 10
2+
from sqlspec.adapters.duckdb import DuckDBConfig
3+
4+
# In-memory
5+
config_inmemory = DuckDBConfig()
6+
7+
# Persistent
8+
config_persistent = DuckDBConfig(
9+
pool_config={"database": "analytics.duckdb"}
10+
)
11+
12+
# with spec.provide_session(config) as session:
13+
# session.execute(...) etc.
14+
Lines changed: 14 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,14 @@
1+
# Example from docs/usage/drivers_and_querying.rst - code-block 11
2+
from sqlspec.adapters.oracledb import OracleDBConfig
3+
4+
config = OracleDBConfig(
5+
pool_config={
6+
"user": "myuser",
7+
"password": "mypassword",
8+
"dsn": "localhost:1521/ORCLPDB",
9+
}
10+
)
11+
12+
# with spec.provide_session(config) as session:
13+
# result = session.execute("SELECT * FROM employees WHERE employee_id = :id", id=100)
14+
Lines changed: 14 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,14 @@
1+
# Example from docs/usage/drivers_and_querying.rst - code-block 12
2+
from sqlspec.adapters.bigquery import BigQueryConfig
3+
import datetime
4+
5+
config = BigQueryConfig(
6+
pool_config={
7+
"project": "my-project",
8+
"credentials": None,
9+
}
10+
)
11+
12+
# with spec.provide_session(config) as session:
13+
# result = session.execute("SELECT DATE(timestamp) as date, COUNT(*) as events FROM `project.dataset.events` WHERE timestamp >= @start_date GROUP BY date", start_date=datetime.date(2025,1,1))
14+
Lines changed: 24 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,24 @@
1+
# Example from docs/usage/drivers_and_querying.rst - code-block 13
2+
# SELECT query example
3+
# result = session.execute("SELECT * FROM users WHERE id = ?", 1)
4+
5+
# INSERT query example
6+
# result = session.execute(
7+
# "INSERT INTO users (name, email) VALUES (?, ?)",
8+
# "Alice",
9+
# "alice@example.com"
10+
# )
11+
12+
# UPDATE example
13+
# result = session.execute(
14+
# "UPDATE users SET email = ? WHERE id = ?",
15+
# "newemail@example.com",
16+
# 1
17+
# )
18+
# print(f"Updated {result.rows_affected} rows")
19+
20+
# DELETE example
21+
# result = session.execute("DELETE FROM users WHERE id = ?", 1)
22+
23+
# These lines are examples and require a session object to run.
24+
Lines changed: 22 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,22 @@
1+
# Example from docs/usage/drivers_and_querying.rst - code-block 14
2+
# Batch insert example
3+
# session.execute_many(
4+
# "INSERT INTO users (name, email) VALUES (?, ?)",
5+
# [
6+
# ("Alice", "alice@example.com"),
7+
# ("Bob", "bob@example.com"),
8+
# ("Charlie", "charlie@example.com"),
9+
# ]
10+
# )
11+
12+
# Batch update example
13+
# session.execute_many(
14+
# "UPDATE users SET status = ? WHERE id = ?",
15+
# [
16+
# ("active", 1),
17+
# ("inactive", 2),
18+
# ]
19+
# )
20+
21+
# Examples require a session object to run.
22+
Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,7 @@
1+
# Example from docs/usage/drivers_and_querying.rst - code-block 15
2+
# SELECT and all() example
3+
# users = session.execute("SELECT * FROM users WHERE status = ?", "active")
4+
# returns list of dicts
5+
6+
# Placeholder only
7+
Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,8 @@
1+
# Example from docs/usage/drivers_and_querying.rst - code-block 16
2+
# select_one example
3+
# user = session.select_one("SELECT * FROM users WHERE id = ?", 1)
4+
# Raises NotFoundError if no results
5+
# Raises MultipleResultsFoundError if multiple results
6+
7+
# Placeholder only
8+
Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,8 @@
1+
# Example from docs/usage/drivers_and_querying.rst - code-block 17
2+
# select_one_or_none example
3+
# user = session.select_one_or_none("SELECT * FROM users WHERE email = ?", "nobody@example.com")
4+
# Returns dict or None
5+
# Raises MultipleResultsFoundError if multiple results
6+
7+
# Placeholder only
8+
Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,7 @@
1+
# Example from docs/usage/drivers_and_querying.rst - code-block 18
2+
# select_value example
3+
# count = session.select_value("SELECT COUNT(*) FROM users")
4+
# latest_id = session.select_value("SELECT MAX(id) FROM users")
5+
6+
# Placeholder only
7+

0 commit comments

Comments
 (0)