提交

cloudfunctions/quickstartFunctions/config/database.js

@@ -0,0 +1,22 @@
+const cloud = require('wx-server-sdk')
+
+cloud.init({
+  env: cloud.DYNAMIC_CURRENT_ENV
+})
+const db = cloud.database();
+async function init() {
+  try {
+    await db.createCollection('questionBank')
+    await db.createCollection('questionRecord')
+    await db.createCollection('user')
+  } catch (err) {
+    console.log('------>', err)
+  }
+}
+
+
+module.exports = {
+  cloud,
+  db,
+  init
+}

cloudfunctions/quickstartFunctions/createQuestionRecord/index.js

@@ -1,9 +1,5 @@
-const cloud = require('wx-server-sdk')
+const { cloud, db } = require("../config/database");
 
-cloud.init({
-  env: cloud.DYNAMIC_CURRENT_ENV
-})
-const db = cloud.database()
 const QuestionRecord = db.collection("questionRecord");
 
 // 修改数据库信息云函数入口函数

cloudfunctions/quickstartFunctions/createUser/index.js

@@ -1,9 +1,4 @@
-const cloud = require('wx-server-sdk')
-
-cloud.init({
-  env: cloud.DYNAMIC_CURRENT_ENV
-})
-const db = cloud.database()
+const { cloud, db } = require("../config/database");
 const user = db.collection("user");
 
 // 修改数据库信息云函数入口函数

cloudfunctions/quickstartFunctions/getQuestionRecord/index.js

@@ -1,9 +1,4 @@
-const cloud = require('wx-server-sdk')
-
-cloud.init({
-  env: cloud.DYNAMIC_CURRENT_ENV
-})
-const db = cloud.database()
+const { cloud, db } = require("../config/database");
 const QuestionRecord = db.collection("questionRecord");
 
 // 修改数据库信息云函数入口函数

cloudfunctions/quickstartFunctions/getUser/index.js

@@ -1,9 +1,4 @@
-const cloud = require('wx-server-sdk')
-
-cloud.init({
-  env: cloud.DYNAMIC_CURRENT_ENV
-})
-const db = cloud.database();
+const { cloud, db } = require("../config/database");
 const user = db.collection("user");
 
 // 修改数据库信息云函数入口函数

cloudfunctions/quickstartFunctions/index.js

@@ -4,8 +4,11 @@ const questionBank = require('./questionBank/index')
 const createQuestionRecord = require('./createQuestionRecord/index')
 const getQuestionRecord = require('./getQuestionRecord/index')
 
+const { init } = require("./config/database")
+
 // 云函数入口函数
 exports.main = async (event, context) => {
+  await init();
   switch (event.type) {
     case 'getUser':
       // 获取用户信息

cloudfunctions/quickstartFunctions/questionBank/index.js

@@ -1,9 +1,4 @@
-const cloud = require('wx-server-sdk')
-
-cloud.init({
-  env: cloud.DYNAMIC_CURRENT_ENV
-})
-const db = cloud.database();
+const { cloud, db } = require("../config/database");
 const questionBank = db.collection("questionBank");
 
 // 修改数据库信息云函数入口函数