20251217 #1 postgre sql 연결 및 테이블 생성

.coderabbit.yaml

@@ -0,0 +1,18 @@
+# yaml-language-server: $schema=https://coderabbit.ai/integrations/schema.v2.json
+language: "ko-KR"
+early_access: false
+reviews:
+  profile: "chill"
+  request_changes_workflow: false
+  high_level_summary: true
+  poem: true
+  review_status: true
+  collapse_walkthrough: false
+  auto_review:
+    enabled: true
+    drafts: false
+    base_branches:
+      - main
+      - test
+chat:
+  auto_reply: true

app/config/database.py

@@ -1,2 +1,27 @@
-# 빈 파일 - DB 연결 설정
+from typing import AsyncGenerator
 
+from sqlalchemy.ext.asyncio import AsyncSession, async_sessionmaker, create_async_engine
+
+from app.config.settings import get_settings
+
+_settings = get_settings()
+
+_engine = create_async_engine(
+  _settings.postgres_url,
+  pool_pre_ping=True,
+)
+
+_async_session_factory = async_sessionmaker(
+  bind=_engine,
+  expire_on_commit=False,
+  autoflush=False,
+)
+
+
+def get_async_session_factory() -> async_sessionmaker[AsyncSession]:
+  return _async_session_factory
+
+
+async def get_async_session() -> AsyncGenerator[AsyncSession, None]:
+  async with _async_session_factory() as session:
+    yield session

app/config/settings.py

@@ -1,2 +1,46 @@
-# 빈 파일 - 환경 변수 설정
+from functools import lru_cache
 
+from pydantic_settings import BaseSettings, SettingsConfigDict
+
+
+class Settings(BaseSettings):
+  """
+  .env 에서 환경변수 로딩
+  """
+
+  model_config = SettingsConfigDict(
+    env_file=".env",
+    env_file_encoding="utf-8",
+    case_sensitive=False,
+    extra="ignore"
+  )
+
+  # GitHub API 설정
+  github_api_base_url: str
+
+  # Ollama 설정
+  ollama_base_url: str
+  ollama_api_key: str
+  ollama_model: str
+  ollama_timeout_seconds: int
+
+  # Qdrant 설정
+  qdrant_base_url: str
+  qdrant_collection: str
+  qdrant_api_key: str
+
+  # 텍스트 청크 설정
+  text_chunk_max_chars: int
+  text_chunk_overlap_chars: int
+  text_chunk_hard_max_chars: int
+
+  # 동시성 설정
+  concurrency_embedding_max_concurrency: int
+
+  # PostgreSQL 설정
+  postgres_url: str
+
+
+@lru_cache(maxsize=1)
+def get_settings() -> Settings:
+  return Settings()

app/models/base.py

@@ -0,0 +1,9 @@
+from sqlalchemy.orm import DeclarativeBase
+
+
+class Base(DeclarativeBase):
+  """
+  SQLAlchemy Declarative Base
+  - 모든 엔티티는 Base 상속
+  """
+  pass

app/models/enums/source_type.py

@@ -0,0 +1,17 @@
+from enum import Enum
+
+
+class SourceType(str, Enum):
+  """
+  깃허브 임베딩 대상 SourceType
+  - Repository: 레포 파일/문서 (README 등)
+  - ISSUE: 이슈
+  - PULL_REQUEST: PR
+  - COMMIT: 커밋
+  - RELEASE: 릴리즈
+  """
+  REPOSITORY = "REPOSITORY"
+  ISSUE = "ISSUE"
+  PULL_REQUEST = "PULL_REQUEST"
+  COMMIT = "COMMIT"
+  RELEASE = "RELEASE"

app/models/github_cursor.py

@@ -0,0 +1,29 @@
+import uuid
+from datetime import datetime
+
+from sqlalchemy import Enum as SqlEnum
+from sqlalchemy import UniqueConstraint, Index, String, DateTime, func
+from sqlalchemy.dialects.postgresql.base import UUID
+from sqlalchemy.orm import Mapped, mapped_column
+
+from app.models.base import Base
+from app.models.enums.source_type import SourceType
+
+
+class GithubCursorEntity(Base):
+  __tablename__ = "github_cursor"
+  __table_args__ = (
+    UniqueConstraint("repository_name", "source_type", name="uq_github_cursor"),
+    Index("idx_github_cursor_repo_type", "repository_name", "source_type")
+  )
+
+  id: Mapped[uuid.UUID] = mapped_column(UUID(as_uuid=True), primary_key=True, default=uuid.uuid4)
+
+  repository_name: Mapped[str] = mapped_column(String(200), nullable=False)
+
+  source_type: Mapped[SourceType] = mapped_column(SqlEnum(SourceType, native_enum=False), nullable=False)
+
+  cursor_value: Mapped[str] = mapped_column(String(500), nullable=False)
+
+  created_at: Mapped[datetime] = mapped_column(DateTime(timezone=True), nullable=False, server_default=func.now())
+  updated_at: Mapped[datetime] = mapped_column(DateTime(timezone=True), nullable=False, server_default=func.now(), onupdate=func.now())

app/repositories/github_cursor_repository.py

@@ -0,0 +1,45 @@
+import uuid
+from typing import Optional
+
+from sqlalchemy import select, func
+from sqlalchemy.dialects.postgresql import insert
+from sqlalchemy.ext.asyncio import AsyncSession
+
+from app.models.enums.source_type import SourceType
+from app.models.github_cursor import GithubCursorEntity
+
+
+class GithubCursorRepository:
+  async def find_by_repository_name_and_source_type(
+    self,
+    session: AsyncSession,
+    repository_name: str,
+    source_type: SourceType,
+  ) -> Optional[GithubCursorEntity]:
+    query = select(GithubCursorEntity).where(
+      GithubCursorEntity.repository_name == repository_name,
+      GithubCursorEntity.source_type == source_type,
+    )
+    result = await session.execute(query)
+    return result.scalar_one_or_none()
+
+  async def upsert(
+    self,
+    session: AsyncSession,
+    repository_name: str,
+    source_type: SourceType,
+    cursor_value: str,
+  ) -> None:
+    query = insert(GithubCursorEntity).values(
+      id=uuid.uuid4(),
+      repository_name=repository_name,
+      source_type=source_type,
+      cursor_value=cursor_value,
+    ).on_conflict_do_update(
+      index_elements=["repository_name", "source_type"],
+      set_={
+        "cursor_value": cursor_value,
+        "updated_at": func.now(),
+      },
+    )
+    await session.execute(query)

requirements.txt

@@ -1,13 +1,45 @@
+alembic==1.17.2
 annotated-doc==0.0.4
 annotated-types==0.7.0
 anyio==4.12.0
+asyncpg==0.31.0
+certifi==2025.11.12
+cffi==2.0.0
+charset-normalizer==3.4.4
 click==8.3.1
-fastapi==0.124.4
+cryptography==46.0.3
+Deprecated==1.3.1
+fastapi==0.127.0
+greenlet==3.3.0
+grpcio==1.76.0
+grpcio-tools==1.76.0
 h11==0.16.0
+h2==4.3.0
+hpack==4.1.0
+httpcore==1.0.9
+httpx==0.28.1
+hyperframe==6.1.0
 idna==3.11
+Mako==1.3.10
+MarkupSafe==3.0.3
+numpy==2.4.0
+portalocker==3.2.0
+protobuf==6.33.2
+pycparser==2.23
 pydantic==2.12.5
+pydantic-settings==2.12.0
 pydantic_core==2.41.5
+PyGithub==2.8.1
+PyJWT==2.10.1
+PyNaCl==1.6.1
+python-dotenv==1.2.1
+qdrant-client==1.16.2
+requests==2.32.5
+setuptools==80.9.0
+SQLAlchemy==2.0.45
 starlette==0.50.0
 typing-inspection==0.4.2
 typing_extensions==4.15.0
-uvicorn==0.38.0
+urllib3==2.6.2
+uvicorn==0.40.0
+wrapt==2.0.1

sql/V20251222_141233__create_github_cursor_table.sql

@@ -0,0 +1,16 @@
+CREATE TABLE IF NOT EXISTS github_cursor (
+    id UUID PRIMARY KEY,
+    repository_name VARCHAR(200) NOT NULL,
+    source_type VARCHAR(50) NOT NULL,
+    cursor_value VARCHAR(500) NOT NULL,
+    created_at TIMESTAMPTZ NOT NULL DEFAULT NOW(),
+    updated_at TIMESTAMPTZ NOT NULL DEFAULT NOW(),
+    CONSTRAINT uq_github_cursor UNIQUE (repository_name, source_type),
+
+    CONSTRAINT ck_github_cursor_source_type
+        CHECK (source_type IN ('REPOSITORY', 'ISSUE', 'PULL_REQUEST', 'COMMIT', 'RELEASE'))
+);
+
+-- 인덱스 생성
+CREATE INDEX IF NOT EXISTS idx_github_cursor_repo_type
+    ON github_cursor (repository_name, source_type);