Mongo DB

데이터플로우에서 MongoDB 사용하는 법

현재 데이터플로우에서는 5가지 액션을 지원합니다.

• 검색

• 집계

• 단일 문서 삽입

• 단일 문서 업데이트

• 단일 문서 삭제

검색

• 컬렉션 (테이블 명): 검색할 컬렉션 이름을 입력해줍니다.

• 쿼리:

1. 전체 검색
{}

2. email이 '[e-mail]' 인 데이터 검색
{
    "email": "[e-mail]"
}

3. lang이 'English' 이면서 name이 '한지우'인 데이터 검색
{
    "lang": "English",
    "name": "한지우"
}

4. ObjectId가 '6457b0705db56cba057073d3'인 데이터 검색
{
    "_id": "6457b0705db56cba057073d3"
}

• 쿼리가 제대로 작성되었는지 확인하기 위해 오른쪽 어시스턴트 영역에서 실행 버튼을 누릅니다.

어시스턴트에는 실행된 쿼리의 첫번째 열만 보여집니다.

집계

• 컬렉션 (테이블 명): 집계할 컬렉션 이름을 입력해줍니다.

• 쿼리:

1. 전체 데이터의 총 개수
[
    {
        "$group": {
            "_id": null,
            "count": {
                "$sum": 1
            }
        }
    }
]

2. lang이 'English' 인 데이터의 총 개수
[
    {
        "$match": {
            "lang": "English"
        }
    },
    {
        "$group": {
            "_id": null,
            "count": {
                "$sum": 1
            }
        }
    }
]

단일 문서 삽입

• 컬렉션 (테이블 명): 삽입할 컬렉션 이름을 입력해줍니다.

• 쿼리:

1. ObjectId 포함
{
    "_id": "64670b713052ec002554e000",
    "id": "103",
    "org_name": "Powertask",
    "name": "홍길동",
    "email": "[e-mail]",
    "phone": "01012341234",
    "lang": "Korean",
    "create_at": "2023. 05. 19. 14:00:00"
}

2. ObjectId 미 포함(ObjectId가 자동으로 생성됩니다.)
{
    "id": 100,
    "org_name": "Powertask",
    "name": "홍길동",
    "email": "[e-mail]",
    "phone": "01012341234",
    "lang": "Korean",
    "create_at": "2023. 05. 19. 14:00:00"
}

쿼리 결과가 여러개여도, 단일 문서 삽입은 1건만 실행됩니다.

단일 문서 업데이트

• 컬렉션 (테이블 명): 업데이트할 컬렉션 이름을 입력해줍니다.

• 쿼리:

1. ObjectId가 646ad3136bd9d444d3ff5000인 데이터의 Id, create_at 을 변경
{
    "_id": "646ad3136bd9d444d3ff5000"
}
업데이트 쿼리 (필수)
{
    "$set": {
        "id": 211,
        "create_at": "2023. 05. 22. 11:00:00"
    }
}
옵션 (생략가능)
{}

2. id가 219 인 데이터의 Id, create_at을 변경 (옵션 추가: 없으면 데이터 추가)
쿼리
{
    "id": 219
}
업데이트 쿼리
{
    "$set": {
        "id": 222,
        "create_at": "2023. 05. 22. 11:30:00"
    }
}
옵션
{
    "upsert": true
}

쿼리 결과가 여러개여도, 단일 문서 업데이트는 1건만 실행됩니다.

단일 문서 삭제

• 컬렉션 (테이블 명): 삭제할 컬렉션 이름을 입력해줍니다.

• 쿼리:

id가 219 인 데이터를 삭제
{
    "id": 219
}

쿼리 결과가 여러개여도, 단일 문서 삭제는 1건만 실행됩니다.