ArangoDB

// ArangoDB Node.js 드라이버 (arangojs)
const { Database, aql } = require('arangojs');

async function main() {
    // 데이터베이스 연결
    const db = new Database({
        url: 'http://localhost:8529',
        databaseName: 'myapp',
        auth: { username: 'root', password: 'password' }
    });

    // 컬렉션 접근
    const products = db.collection('products');
    const categories = db.collection('categories');
    const belongs_to = db.collection('belongs_to'); // 엣지

    // 문서 삽입 (upsert 패턴)
    await db.query(aql`
        UPSERT { _key: "laptop-001" }
        INSERT {
            _key: "laptop-001",
            name: "MacBook Pro",
            price: 2499,
            specs: { cpu: "M3", ram: "16GB", storage: "512GB" }
        }
        UPDATE { price: 2499 }
        IN products
    `);

    // 중첩 문서 쿼리
    const cursor = await db.query(aql`
        FOR p IN products
            FILTER p.specs.ram == "16GB"
            SORT p.price DESC
            RETURN { name: p.name, price: p.price }
    `);

    console.log('16GB RAM 제품:');
    for await (const product of cursor) {
        console.log(`  ${product.name}: $${product.price}`);
    }

    // 그래프 순회 - 카테고리별 제품 탐색
    const categoryProducts = await db.query(aql`
        FOR cat IN categories
            FILTER cat.name == "Electronics"
            FOR product IN 1..1 INBOUND cat belongs_to
                COLLECT category = cat.name INTO products = product
                RETURN {
                    category: category,
                    products: products[*].name,
                    total: LENGTH(products)
                }
    `);

    console.log('\n카테고리별 제품:');
    for await (const result of categoryProducts) {
        console.log(`  ${result.category}: ${result.total}개`);
    }

    // 트랜잭션 처리
    const trx = await db.beginTransaction({
        read: ['products'],
        write: ['orders', 'products']
    });

    try {
        await trx.step(() => db.query(aql`
            INSERT {
                product_id: "laptop-001",
                quantity: 1,
                total: 2499,
                created_at: DATE_NOW()
            } INTO orders
        `));

        await trx.step(() => db.query(aql`
            UPDATE { _key: "laptop-001" }
            WITH { stock: OLD.stock - 1 }
            IN products
        `));

        await trx.commit();
        console.log('\n주문 완료!');
    } catch (err) {
        await trx.abort();
        console.error('트랜잭션 실패:', err.message);
    }
}

main().catch(console.error);

// ============================================
// AQL 기본 쿼리
// ============================================

// 문서 조회 (기본)
FOR user IN users
    FILTER user.age >= 25 AND user.status == "active"
    SORT user.created_at DESC
    LIMIT 10
    RETURN user

// 문서 삽입
INSERT {
    name: "신규 사용자",
    email: "new@example.com",
    created_at: DATE_NOW()
} INTO users
RETURN NEW

// 문서 업데이트
UPDATE "user123" WITH {
    last_login: DATE_NOW(),
    login_count: OLD.login_count + 1
} IN users
RETURN NEW


// ============================================
// 그래프 순회 (Graph Traversal)
// ============================================

// 1단계 팔로우 관계
FOR user IN users
    FILTER user._key == "alice"
    FOR friend IN 1..1 OUTBOUND user follows
        RETURN friend.name

// 최대 3단계까지 관계 탐색
FOR user IN users
    FILTER user._key == "alice"
    FOR connected, edge, path IN 1..3 ANY user follows
        OPTIONS { bfs: true, uniqueVertices: 'global' }
        RETURN {
            person: connected.name,
            depth: LENGTH(path.edges),
            via: path.vertices[*].name
        }

// 최단 경로 찾기
FOR v, e IN OUTBOUND SHORTEST_PATH
    'users/alice' TO 'users/charlie'
    GRAPH 'social'
    RETURN { vertex: v.name, edge: e }


// ============================================
// 조인과 집계
// ============================================

// 컬렉션 조인
FOR order IN orders
    FOR user IN users
        FILTER order.user_id == user._key
        RETURN {
            order_id: order._key,
            customer: user.name,
            total: order.amount
        }

// 그룹화 및 집계
FOR order IN orders
    COLLECT user_id = order.user_id
    AGGREGATE total = SUM(order.amount), count = LENGTH(1)
    SORT total DESC
    RETURN {
        user: user_id,
        order_count: count,
        total_spent: total
    }


// ============================================
// 전문 검색 (Full-Text Search)
// ============================================

// Analyzer 뷰 사용
FOR doc IN product_search
    SEARCH ANALYZER(
        doc.description IN TOKENS("wireless bluetooth headphones", "text_en"),
        "text_en"
    )
    SORT BM25(doc) DESC
    LIMIT 10
    RETURN { name: doc.name, score: BM25(doc) }