|
|
@@ -276,6 +276,8 @@ func migrateDB() error { |
|
|
&SubscriptionPreConsumeRecord{}, |
|
|
&SubscriptionPreConsumeRecord{}, |
|
|
&CustomOAuthProvider{}, |
|
|
&CustomOAuthProvider{}, |
|
|
&UserOAuthBinding{}, |
|
|
&UserOAuthBinding{}, |
|
|
|
|
|
&ChannelPricing{}, |
|
|
|
|
|
&PricingTag{}, |
|
|
) |
|
|
) |
|
|
if err != nil { |
|
|
if err != nil { |
|
|
return err |
|
|
return err |
|
|
@@ -324,6 +326,8 @@ func migrateDBFast() error { |
|
|
{&SubscriptionPreConsumeRecord{}, "SubscriptionPreConsumeRecord"}, |
|
|
{&SubscriptionPreConsumeRecord{}, "SubscriptionPreConsumeRecord"}, |
|
|
{&CustomOAuthProvider{}, "CustomOAuthProvider"}, |
|
|
{&CustomOAuthProvider{}, "CustomOAuthProvider"}, |
|
|
{&UserOAuthBinding{}, "UserOAuthBinding"}, |
|
|
{&UserOAuthBinding{}, "UserOAuthBinding"}, |
|
|
|
|
|
{&ChannelPricing{}, "ChannelPricing"}, |
|
|
|
|
|
{&PricingTag{}, "PricingTag"}, |
|
|
} |
|
|
} |
|
|
// 动态计算migration数量,确保errChan缓冲区足够大 |
|
|
// 动态计算migration数量,确保errChan缓冲区足够大 |
|
|
errChan := make(chan error, len(migrations)) |
|
|
errChan := make(chan error, len(migrations)) |
|
|
|