dataBase.js 2.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596
  1. const dbPath = '_doc/locateDB.db'
  2. const name = 'locateDB'
  3. //const ApiUrl = 'http://192.168.1.7:8080'
  4. const getdata = function(api,data,successc,failc){
  5. //打开数据库
  6. if(api=='openDB'){
  7. plus.sqlite.openDatabase({
  8. name:name,
  9. path:dbPath,
  10. success: res=> {
  11. successc(res);
  12. },
  13. fail: function (err) {
  14. failc(err);
  15. },
  16. });
  17. }
  18. if(api=='DBisOpen'){//判断数据库是否打开
  19. if(plus.sqlite.isOpenDatabase({name:name,path:dbPath})){
  20. successc(true);
  21. }
  22. else{
  23. successc(false);
  24. }
  25. }
  26. //关闭数据库
  27. if(api=='closeDB'){
  28. plus.sqlite.openDatabase({
  29. name:name,
  30. success: res=> {
  31. successc(res);
  32. },
  33. fail: function (err) {
  34. failc(err);
  35. },
  36. });
  37. }
  38. //创建用户表(好友)
  39. if(api=='CTableuser'){
  40. plus.sqlite.executeSql({
  41. name:name,
  42. sql:'create table if not exists userfl("userid" CHAR(20),"NickName" CHAR(32),"UserName" CHAR(32),"illustrate" CHAR(120),"newmsg" int(8))',
  43. success: res=> {
  44. successc(res);
  45. },
  46. fail: function (err) {
  47. failc(err);
  48. },
  49. })
  50. }
  51. //创建消息表
  52. if(api=='CTablemsg'){
  53. plus.sqlite.executeSql({
  54. name:name,
  55. sql:'create table if not exists msglist("userid" CHAR(20),"time" CHAR(32),"msg" CHAR(32),"type" int(8))',
  56. success: res=> {
  57. successc(res);
  58. },
  59. fail: function (err) {
  60. failc(err);
  61. },
  62. })
  63. }
  64. //插入用户(好友)
  65. if(api=='insertUser'){
  66. plus.sqlite.executeSql({
  67. name:name,
  68. sql:'if not exists(select * from userfl where userid=001) begin insert into userfl(userid,NickName,UserName,illustrate,newmsg) values(userid,NickName,UserName,illustrate,newmsg)',
  69. success: res=> {
  70. successc(res);
  71. },
  72. fail: function (err) {
  73. failc(err);
  74. },
  75. })
  76. }
  77. //插入消息
  78. if(api=='insertmsg'){
  79. plus.sqlite.executeSql({
  80. name:name,
  81. sql:'if not exists(select * from userfl where userid=001) begin insert into userfl(userid,NickName,UserName,illustrate,newmsg) values(userid,NickName,UserName,illustrate,newmsg)',
  82. success: res=> {
  83. successc(res);
  84. },
  85. fail: function (err) {
  86. failc(err);
  87. },
  88. })
  89. }
  90. }
  91. module.exports = getdata;