fix: comments

actiontech · Oct 25, 2024 · 5710d6c · 5710d6c
1 parent 230c55e
commit 5710d6c
Show file tree

Hide file tree

Showing 4 changed files with 8 additions and 4 deletions.
diff --git a/sqle/server/auditplan/task_type_mysql_processlist.go b/sqle/server/auditplan/task_type_mysql_processlist.go
@@ -3,6 +3,7 @@ package auditplan
 import (
 	"context"
 	"fmt"
+	"github.com/actiontech/sqle/sqle/errors"
 	"strconv"
 	"time"
 
@@ -82,7 +83,7 @@ func (at *MySQLProcessListTaskV2) ExtractSQL(logger *logrus.Entry, ap *AuditPlan
 		return nil, fmt.Errorf("get instance fail, error: %v", err)
 	}
 	if !exist {
-		return nil, fmt.Errorf("instance: %v is not exist", ap.InstanceID)
+		return nil, errors.NewInstanceNoExistErr()
 	}
 
 	db, err := executor.NewExecutor(logger, &driverV2.DSN{

diff --git a/sqle/server/auditplan/task_type_mysql_schema_meta.go b/sqle/server/auditplan/task_type_mysql_schema_meta.go
@@ -4,6 +4,7 @@ import (
 	"context"
 	"encoding/json"
 	"fmt"
+	"github.com/actiontech/sqle/sqle/errors"
 	"strconv"
 	"time"
 
@@ -52,7 +53,7 @@ func (at *BaseSchemaMetaTaskV2) extractSQL(logger *logrus.Entry, ap *AuditPlan,
 		return nil, fmt.Errorf("get instance fail, error: %v", err)
 	}
 	if !exist {
-		return nil, fmt.Errorf("instance: %v is not exist", ap.InstanceID)
+		return nil, errors.NewInstanceNoExistErr()
 	}
 	db, err := executor.NewExecutor(logger, &driverV2.DSN{
 		Host:             instance.Host,

diff --git a/sqle/server/auditplan/task_type_oracle_topsql.go b/sqle/server/auditplan/task_type_oracle_topsql.go
@@ -3,6 +3,7 @@ package auditplan
 import (
 	"context"
 	"fmt"
+	"github.com/actiontech/sqle/sqle/errors"
 	"strconv"
 	"time"
 
@@ -100,7 +101,7 @@ func (at *OracleTopSQLTaskV2) ExtractSQL(logger *logrus.Entry, ap *AuditPlan, pe
 		return nil, fmt.Errorf("get instance fail, error: %v", err)
 	}
 	if !exist {
-		return nil, fmt.Errorf("instance: %v is not exist", ap.InstanceID)
+		return nil, errors.NewInstanceNoExistErr()
 	}
 	// This depends on: https://github.com/actiontech/sqle-oracle-plugin.
 	// If your Oracle db plugin does not implement the parameter `service_name`,

diff --git a/sqle/server/pipeline/pipeline.go b/sqle/server/pipeline/pipeline.go
@@ -3,6 +3,7 @@ package pipeline
 import (
 	"context"
 	"fmt"
+	"github.com/actiontech/sqle/sqle/errors"
 	"net"
 	"net/url"
 	"time"
@@ -46,7 +47,7 @@ func (node PipelineNode) IntegrationInfo(ctx context.Context, projectName string
 			return "", err
 		}
 		if !exist {
-			return "", fmt.Errorf("instance: %v is not exist", node.InstanceID)
+			return "", errors.NewInstanceNoExistErr()
 		}
 		node.InstanceName = instance.Name
 	}