# MongoDB

## 数据自动入Mongo库使用须知

- 使用`MongoDb`存储数据，需要使用`MongoPipeline`

示例:

```python
import feapder
from feapder import Item


class TestMongo(feapder.AirSpider):
    __custom_setting__ = dict(
        ITEM_PIPELINES=["feapder.pipelines.mongo_pipeline.MongoPipeline"],
        MONGO_IP="localhost",
        MONGO_PORT=27017,
        MONGO_DB="feapder",
        MONGO_USER_NAME="",
        MONGO_USER_PASS="",
    )

    def start_requests(self):
        yield feapder.Request("https://www.baidu.com")

    def parse(self, request, response):
        title = response.xpath("//title/text()").extract_first()  # 取标题
        item = Item()  # 声明一个item
        item.table_name = "test_mongo" # 指定存储的表名
        item.title = title  # 给item属性赋值
        yield item  # 返回item， item会自动批量入库


if __name__ == "__main__":
    TestMongo().start()
```


## 直接使用

### 连接

```python
from feapder.db.mongodb import MongoDB


db = MongoDB(
    ip="localhost", port=27017, db="feapder", user_name="feapder", user_pass="feapder123"
)
```

若环境变量中配置了数据库连接方式或者setting中已配置，则可不传参 

```python
db = MongoDB()
```
    
或者可以根据url连接

```python
db = MongoDB.from_url("mongodb://username:password@ip:port/db")
```
    
### 方法

> MongoDB封装了增删改查等方法，方便使用

#### 查

```python
def find(self, table, limit=0) -> List[Dict]:
    """
    @summary:
    无数据： 返回()
    有数据： 若limit == 1 则返回 (data1, data2)
            否则返回 ((data1, data2),)
    ---------
    @param table:
    @param limit:
    ---------
    @result:
    """
```
    

#### 增

```python
def add(self, table, data, **kwargs):
    """

    Args:
        table:
        data:
        kwargs:
            auto_update: 覆盖更新，将替换唯一索引重复的数据，默认False
            update_columns: 更新指定的列（如果数据的唯一索引存在，则更新指定字段，如 update_columns = ["name", "title"]
            insert_ignore: 唯一索引冲突时是否忽略，默认为False
            condition_fields: 用于条件查找的字段，默认以`_id`作为查找条件，默认：['_id']
            exception_callfunc: 异常回调

    Returns: 添加行数

    """
```

```python
def add_batch(self, table: str, datas: List[Dict], **kwargs):
    """
    @summary: 批量添加数据
    ---------
    @param command: 字典
    @param datas: 列表 [[..], [...]]
    @param **kwargs:
        auto_update: 覆盖更新，将替换唯一索引重复的数据，默认False
        update_columns: 更新指定的列（如果数据的唯一索引存在，则更新指定字段，如 update_columns = ["name", "title"]
        update_columns_value: 指定更新的字段对应的值
        condition_fields: 用于条件查找的字段，默认以`_id`作为查找条件，默认：['_id']
    ---------
    @result: 添加行数
    """
```

#### 更新

```python
def update(self, coll_name, data: Dict, condition: Dict, upsert: bool = False):
    """
    更新
    Args:
        coll_name: 集合名
        data: 单条数据 {"xxx":"xxx"}
        condition: 更新条件 {"_id": "xxxx"}
        upsert: 数据不存在则插入,默认为 False

    Returns: True / False
    """
```

#### 删除

```python
def delete(self, table, condition: Dict):
    """
    删除
    Args:
        table:
        condition: 查找条件
    Returns: True / False
    """
```