You can not select more than 25 topics Topics must start with a chinese character,a letter or number, can include dashes ('-') and can be up to 35 characters long.

package.go 6.7 kB

2 years ago
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205
  1. package db
  2. import (
  3. "database/sql"
  4. "errors"
  5. "fmt"
  6. "github.com/jmoiron/sqlx"
  7. "github.com/samber/lo"
  8. cdssdk "gitlink.org.cn/cloudream/common/sdks/storage"
  9. "gitlink.org.cn/cloudream/storage/common/pkgs/db/model"
  10. )
  11. type PackageDB struct {
  12. *DB
  13. }
  14. func (db *DB) Package() *PackageDB {
  15. return &PackageDB{DB: db}
  16. }
  17. func (db *PackageDB) GetByID(ctx SQLContext, packageID cdssdk.PackageID) (model.Package, error) {
  18. var ret model.Package
  19. err := sqlx.Get(ctx, &ret, "select * from Package where PackageID = ?", packageID)
  20. return ret, err
  21. }
  22. func (db *PackageDB) GetByName(ctx SQLContext, bucketID cdssdk.BucketID, name string) (model.Package, error) {
  23. var ret model.Package
  24. err := sqlx.Get(ctx, &ret, "select * from Package where BucketID = ? and Name = ?", bucketID, name)
  25. return ret, err
  26. }
  27. func (db *PackageDB) BatchTestPackageID(ctx SQLContext, pkgIDs []cdssdk.PackageID) (map[cdssdk.PackageID]bool, error) {
  28. if len(pkgIDs) == 0 {
  29. return make(map[cdssdk.PackageID]bool), nil
  30. }
  31. stmt, args, err := sqlx.In("select PackageID from Package where PackageID in (?)", lo.Uniq(pkgIDs))
  32. if err != nil {
  33. return nil, err
  34. }
  35. var avaiIDs []cdssdk.PackageID
  36. err = sqlx.Select(ctx, &avaiIDs, stmt, args...)
  37. if err != nil {
  38. return nil, err
  39. }
  40. avaiIDMap := make(map[cdssdk.PackageID]bool)
  41. for _, pkgID := range avaiIDs {
  42. avaiIDMap[pkgID] = true
  43. }
  44. return avaiIDMap, nil
  45. }
  46. func (*PackageDB) BatchGetAllPackageIDs(ctx SQLContext, start int, count int) ([]cdssdk.PackageID, error) {
  47. var ret []cdssdk.PackageID
  48. err := sqlx.Select(ctx, &ret, "select PackageID from Package limit ?, ?", start, count)
  49. return ret, err
  50. }
  51. func (db *PackageDB) GetBucketPackages(ctx SQLContext, userID cdssdk.UserID, bucketID cdssdk.BucketID) ([]model.Package, error) {
  52. var ret []model.Package
  53. err := sqlx.Select(ctx, &ret, "select Package.* from UserBucket, Package where UserID = ? and UserBucket.BucketID = ? and UserBucket.BucketID = Package.BucketID", userID, bucketID)
  54. return ret, err
  55. }
  56. // IsAvailable 判断一个用户是否拥有指定对象
  57. func (db *PackageDB) IsAvailable(ctx SQLContext, userID cdssdk.UserID, packageID cdssdk.PackageID) (bool, error) {
  58. var pkgID cdssdk.PackageID
  59. // 先根据PackageID找到Package,然后判断此Package所在的Bucket是不是归此用户所有
  60. err := sqlx.Get(ctx, &pkgID,
  61. "select Package.PackageID from Package, UserBucket where "+
  62. "Package.PackageID = ? and "+
  63. "Package.BucketID = UserBucket.BucketID and "+
  64. "UserBucket.UserID = ?",
  65. packageID, userID)
  66. if err == sql.ErrNoRows {
  67. return false, nil
  68. }
  69. if err != nil {
  70. return false, fmt.Errorf("find package failed, err: %w", err)
  71. }
  72. return true, nil
  73. }
  74. // GetUserPackage 获得Package,如果用户没有权限访问,则不会获得结果
  75. func (db *PackageDB) GetUserPackage(ctx SQLContext, userID cdssdk.UserID, packageID cdssdk.PackageID) (model.Package, error) {
  76. var ret model.Package
  77. err := sqlx.Get(ctx, &ret,
  78. "select Package.* from Package, UserBucket where"+
  79. " Package.PackageID = ? and"+
  80. " Package.BucketID = UserBucket.BucketID and"+
  81. " UserBucket.UserID = ?",
  82. packageID, userID)
  83. return ret, err
  84. }
  85. // 在指定名称的Bucket中查找指定名称的Package
  86. func (*PackageDB) GetUserPackageByName(ctx SQLContext, userID cdssdk.UserID, bucketName string, packageName string) (cdssdk.Package, error) {
  87. var ret model.Package
  88. err := sqlx.Get(ctx, &ret,
  89. "select Package.* from Package, Bucket, UserBucket where"+
  90. " Package.Name = ? and"+
  91. " Package.BucketID = Bucket.BucketID and"+
  92. " Bucket.Name = ? and"+
  93. " UserBucket.UserID = ? and"+
  94. " UserBucket.BucketID = Bucket.BucketID",
  95. packageName, bucketName, userID)
  96. return ret, err
  97. }
  98. func (db *PackageDB) Create(ctx SQLContext, bucketID cdssdk.BucketID, name string) (cdssdk.PackageID, error) {
  99. // 根据packagename和bucketid查询,若不存在则插入,若存在则返回错误
  100. var packageID int64
  101. err := sqlx.Get(ctx, &packageID, "select PackageID from Package where Name = ? AND BucketID = ? for update", name, bucketID)
  102. // 无错误代表存在记录
  103. if err == nil {
  104. return 0, fmt.Errorf("package with given Name and BucketID already exists")
  105. }
  106. // 错误不是记录不存在
  107. if !errors.Is(err, sql.ErrNoRows) {
  108. return 0, fmt.Errorf("query Package by PackageName and BucketID failed, err: %w", err)
  109. }
  110. sql := "insert into Package(Name, BucketID, State) values(?,?,?)"
  111. r, err := ctx.Exec(sql, name, bucketID, cdssdk.PackageStateNormal)
  112. if err != nil {
  113. return 0, fmt.Errorf("insert package failed, err: %w", err)
  114. }
  115. packageID, err = r.LastInsertId()
  116. if err != nil {
  117. return 0, fmt.Errorf("get id of inserted package failed, err: %w", err)
  118. }
  119. return cdssdk.PackageID(packageID), nil
  120. }
  121. // SoftDelete 设置一个对象被删除,并将相关数据删除
  122. func (db *PackageDB) SoftDelete(ctx SQLContext, packageID cdssdk.PackageID) error {
  123. obj, err := db.GetByID(ctx, packageID)
  124. if err != nil {
  125. return fmt.Errorf("get package failed, err: %w", err)
  126. }
  127. // 不是正常状态的Package,则不删除
  128. // TODO 未来可能有其他状态
  129. if obj.State != cdssdk.PackageStateNormal {
  130. return nil
  131. }
  132. err = db.ChangeState(ctx, packageID, cdssdk.PackageStateDeleted)
  133. if err != nil {
  134. return fmt.Errorf("change package state failed, err: %w", err)
  135. }
  136. err = db.ObjectAccessStat().DeleteInPackage(ctx, packageID)
  137. if err != nil {
  138. return fmt.Errorf("delete from object access stat: %w", err)
  139. }
  140. err = db.ObjectBlock().DeleteInPackage(ctx, packageID)
  141. if err != nil {
  142. return fmt.Errorf("delete from object rep failed, err: %w", err)
  143. }
  144. if err := db.PinnedObject().DeleteInPackage(ctx, packageID); err != nil {
  145. return fmt.Errorf("deleting pinned objects in package: %w", err)
  146. }
  147. if err := db.Object().DeleteInPackage(ctx, packageID); err != nil {
  148. return fmt.Errorf("deleting objects in package: %w", err)
  149. }
  150. _, err = db.StoragePackage().SetAllPackageDeleted(ctx, packageID)
  151. if err != nil {
  152. return fmt.Errorf("set storage package deleted failed, err: %w", err)
  153. }
  154. return nil
  155. }
  156. // DeleteUnused 删除一个已经是Deleted状态,且不再被使用的对象。目前可能被使用的地方只有StoragePackage
  157. func (PackageDB) DeleteUnused(ctx SQLContext, packageID cdssdk.PackageID) error {
  158. _, err := ctx.Exec("delete from Package where PackageID = ? and State = ? and "+
  159. "not exists(select StorageID from StoragePackage where PackageID = ?)",
  160. packageID,
  161. cdssdk.PackageStateDeleted,
  162. packageID,
  163. )
  164. return err
  165. }
  166. func (*PackageDB) ChangeState(ctx SQLContext, packageID cdssdk.PackageID, state string) error {
  167. _, err := ctx.Exec("update Package set State = ? where PackageID = ?", state, packageID)
  168. return err
  169. }

本项目旨在将云际存储公共基础设施化,使个人及企业可低门槛使用高效的云际存储服务(安装开箱即用云际存储客户端即可,无需关注其他组件的部署),同时支持用户灵活便捷定制云际存储的功能细节。