微信小程序-利用http_api进行云插入

接着上篇博客
在你的云服务器中，创建一个同名表

接着查看我们的
官方文档

最后，向app.js加入

let res = await request(options);
    let file_id = res.file_id;
//云数据库插入
    options = {
      method: 'POST',
      uri: 'https://api.weixin.qq.com/tcb/databaseadd?access_token=' + access_token + '',
      body: {
        "env": 'ahf-oz31v',
        "query": "db.collection(\"banner\").add({data:{fileId:\"" + file_id + "\"}})"//插入语句
      },
      json: true
    }

    await request(options)

最后，插入也可以了

最后的app.js代码

const router = require('koa-router')()
const config = require('../config.js')
const request = require('request-promise')
const fs = require('fs')
router.get('/', async (ctx, next) => {
  await ctx.render('index', {
    title: 'Hello Koa 2!'
  })
})

router.get('/string', async (ctx, next) => {
  ctx.body = 'koa2 string'
})

router.get('/json', async (ctx, next) => {
  ctx.body = {
    title: 'koa2 json'
  }
})
router.post('/uploadBannerImg', async (ctx, next) => {
  //获取access_token
  var files = ctx.request.files;
  var file = files.file;
  try {
    let options = {
      uri: 'https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=' + config.appid + '&secret=' + config.secret + '',
      json: true
    }
    let { access_token } = await request(options)
    let fileName = `${Date.now()}.jpg`;
    let filePath = `banner/${fileName}`;

    options = {
      method: 'POST',
      uri: 'https://api.weixin.qq.com/tcb/uploadfile?access_token=' + access_token + '',
      body: {
        "env": 'ahf-oz31v',
        "path": filePath,
      },
      json: true,
    }
    let res = await request(options);
    let file_id = res.file_id;
//云数据库插入
    options = {
      method: 'POST',
      uri: 'https://api.weixin.qq.com/tcb/databaseadd?access_token=' + access_token + '',
      body: {
        "env": 'ahf-oz31v',
        "query": "db.collection(\"banner\").add({data:{fileId:\"" + file_id + "\"}})"//插入语句
      },
      json: true
    }

    await request(options)
//云数据库添加
    options = {
      method: 'POST',
      uri: res.url,
      formData: {
        "Signature": res.authorization,
        "key": filePath,
        "x-cos-security-token": res.token,
        "x-cos-meta-fileid": res.cos_file_id,
        "file": {
          value: fs.createReadStream(file.path),
          options: {
            filename: fileName,
            contentType: file.type
          }
        }
      }
    }
    await request(options)
    ctx.body = res;
  } catch (err) {
    console.log(err);
  }
})

module.exports = router

用来比对纠错

总结：使用http_api进行云操作时
1.需要获取access_token

2.上传access_token

3.进行具体操作