update db sysystem filter

Signed-off-by: Jared Tan <[email protected]>

connector/slowsqlconnector/config.go

@@ -23,6 +23,8 @@ type Exemplars struct {
 type Config struct {
 	// Threshold of slow sql. unit is seconds, default 1s.
 	Threshold float64 `mapstructure:"threshold"`
+	// Filter specific db systems, default "h2", "mongodb", "mssql", "mysql", "oracle", "progress", "postgresql", "mariadb", ref: https://opentelemetry.io/docs/specs/semconv/attributes-registry/db/
+	DBSystem []string `mapstructure:"db_system"`
 	// Dimensions defines the list of additional dimensions on top of the provided:
 	// - service.name
 	// - span.name

connector/slowsqlconnector/connector_logs.go

@@ -71,8 +71,10 @@ func (c *logsConnector) ConsumeTraces(ctx context.Context, traces ptrace.Traces)
 				case ptrace.SpanKindClient:
 					// through db.Statement exists represents db client
 					if _, dbSystem := findAttributeValue(dbSystemKey, span.Attributes()); dbSystem {
-						if spanDuration(span) >= c.config.Threshold {
-							c.attrToLogRecord(sl, serviceName, span, resourceAttr)
+						for _, db := range c.config.DBSystem {
+							if db == getValue(span.Attributes(), dbSystemKey) && spanDuration(span) >= c.config.Threshold {
+								c.attrToLogRecord(sl, serviceName, span, resourceAttr)
+							}
 						}
 					}
 				}

connector/slowsqlconnector/factory.go

@@ -27,6 +27,7 @@ func NewFactory() connector.Factory {
 func createDefaultConfig() component.Config {
 	return &Config{
 		Threshold:  1,
+		DBSystem:   []string{"h2", "mongodb", "mssql", "mysql", "oracle", "progress", "postgresql", "mariadb"},
 		Dimensions: []Dimension{},
 	}
 }