faceSetMySql.js 1.9 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768
  1. const mysql = require("mysql");
  2. // prod
  3. const VUE_APP_MYSQL_HOST = "rds7b2sll8un5kz99s0io.mysql.rds.aliyuncs.com";
  4. const VUE_APP_MYSQL_USER_NAME = "exam_cloud";
  5. const VUE_APP_MYSQL_PASSWORD = "examcloud123!@#";
  6. const VUE_APP_MYSQL_DATABASE = "exam_cloud";
  7. // test
  8. // const VUE_APP_MYSQL_HOST = "192.168.10.30";
  9. // const VUE_APP_MYSQL_USER_NAME = "root";
  10. // const VUE_APP_MYSQL_PASSWORD = "root";
  11. // const VUE_APP_MYSQL_DATABASE = "exam_cloud_test";
  12. const connection = mysql.createConnection({
  13. host: VUE_APP_MYSQL_HOST,
  14. user: VUE_APP_MYSQL_USER_NAME,
  15. password: VUE_APP_MYSQL_PASSWORD,
  16. database: VUE_APP_MYSQL_DATABASE
  17. });
  18. connection.connect(err => {
  19. if (err) throw err;
  20. console.log("Database Connected! " + VUE_APP_MYSQL_HOST);
  21. });
  22. function queryFaceSet() {
  23. return new Promise((resolve, reject) => {
  24. connection.query(
  25. `SELECT faceset_token, face_count FROM ec_b_face_set order by face_count asc limit 1`,
  26. (err, rows) => {
  27. if (err) reject(err);
  28. console.log(rows);
  29. if (rows.length == 0) reject("无可用的faceset_token");
  30. if (rows[0].face_count > 8000) {
  31. reject("faceset_token最小的容量已经大于8000,无法继续。");
  32. } else {
  33. resolve(rows[0].faceset_token);
  34. }
  35. }
  36. );
  37. });
  38. }
  39. function updateFaceSet(faceset_token, face_count) {
  40. return new Promise((resolve, reject) => {
  41. connection.query(
  42. `update ec_b_face_set set face_count = ? where faceset_token = ?`,
  43. [face_count, faceset_token],
  44. (err, result) => {
  45. if (err) reject(err);
  46. console.log(`AffectedRows ${result.affectedRows} row(s)`);
  47. console.log(result);
  48. console.log(`更新 ${faceset_token} 的face_count 为 ${face_count}`);
  49. resolve(result);
  50. }
  51. );
  52. });
  53. }
  54. // exports.queryFaceSet = queryFaceSet;
  55. // exports.updateFaceSet = updateFaceSet;
  56. window.DB = {
  57. queryFaceSet,
  58. updateFaceSet
  59. };