mirror of
https://github.com/Syngnat/GoNavi.git
synced 2026-07-09 06:23:29 +08:00
Compare commits
2 Commits
fix/oceanb
...
fix/oceanb
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
9ba3216fa8 | ||
|
|
fca3f0cffb |
@@ -417,9 +417,16 @@ func buildObjectSequenceMetadataQueries(dbType string, dbName string) []objectMe
|
||||
switch dbType {
|
||||
case "oracle", "dameng":
|
||||
if strings.TrimSpace(dbName) == "" {
|
||||
return []objectMetadataQuerySpec{{sql: "SELECT SEQUENCE_NAME AS sequence_name FROM USER_SEQUENCES ORDER BY SEQUENCE_NAME"}}
|
||||
return []objectMetadataQuerySpec{
|
||||
{sql: "SELECT * FROM USER_SEQUENCES ORDER BY SEQUENCE_NAME"},
|
||||
{sql: "SELECT OBJECT_NAME AS sequence_name FROM USER_OBJECTS WHERE OBJECT_TYPE = 'SEQUENCE' ORDER BY OBJECT_NAME"},
|
||||
}
|
||||
}
|
||||
owner := strings.ToUpper(safeDbName)
|
||||
return []objectMetadataQuerySpec{
|
||||
{sql: fmt.Sprintf("SELECT * FROM ALL_SEQUENCES WHERE SEQUENCE_OWNER = '%s' ORDER BY SEQUENCE_NAME", owner)},
|
||||
{sql: fmt.Sprintf("SELECT OWNER AS schema_name, OBJECT_NAME AS sequence_name FROM ALL_OBJECTS WHERE OWNER = '%s' AND OBJECT_TYPE = 'SEQUENCE' ORDER BY OBJECT_NAME", owner)},
|
||||
}
|
||||
return []objectMetadataQuerySpec{{sql: fmt.Sprintf("SELECT SEQUENCE_OWNER AS schema_name, SEQUENCE_NAME AS sequence_name FROM ALL_SEQUENCES WHERE SEQUENCE_OWNER = '%s' ORDER BY SEQUENCE_NAME", strings.ToUpper(safeDbName))}}
|
||||
default:
|
||||
return nil
|
||||
}
|
||||
|
||||
39
internal/app/methods_db_objects_sequence_test.go
Normal file
39
internal/app/methods_db_objects_sequence_test.go
Normal file
@@ -0,0 +1,39 @@
|
||||
package app
|
||||
|
||||
import (
|
||||
"strings"
|
||||
"testing"
|
||||
)
|
||||
|
||||
func TestBuildObjectSequenceMetadataQueriesOracleUsesWildcardAndObjectFallback(t *testing.T) {
|
||||
t.Parallel()
|
||||
|
||||
specs := buildObjectSequenceMetadataQueries("oracle", "sbdev")
|
||||
if len(specs) != 2 {
|
||||
t.Fatalf("expected 2 Oracle sequence metadata queries, got %d", len(specs))
|
||||
}
|
||||
if !strings.Contains(specs[0].sql, "SELECT * FROM ALL_SEQUENCES") {
|
||||
t.Fatalf("expected ALL_SEQUENCES wildcard query, got %q", specs[0].sql)
|
||||
}
|
||||
if strings.Contains(specs[0].sql, "LAST_NUMBER") || strings.Contains(specs[0].sql, "ORDER_FLAG") {
|
||||
t.Fatalf("query should not enumerate optional sequence columns: %q", specs[0].sql)
|
||||
}
|
||||
if !strings.Contains(specs[1].sql, "ALL_OBJECTS") || !strings.Contains(specs[1].sql, "OBJECT_TYPE = 'SEQUENCE'") {
|
||||
t.Fatalf("expected ALL_OBJECTS fallback query, got %q", specs[1].sql)
|
||||
}
|
||||
}
|
||||
|
||||
func TestBuildObjectSequenceMetadataQueriesOracleUserFallbacks(t *testing.T) {
|
||||
t.Parallel()
|
||||
|
||||
specs := buildObjectSequenceMetadataQueries("oracle", "")
|
||||
if len(specs) != 2 {
|
||||
t.Fatalf("expected 2 Oracle user sequence metadata queries, got %d", len(specs))
|
||||
}
|
||||
if specs[0].sql != "SELECT * FROM USER_SEQUENCES ORDER BY SEQUENCE_NAME" {
|
||||
t.Fatalf("unexpected USER_SEQUENCES query: %q", specs[0].sql)
|
||||
}
|
||||
if !strings.Contains(specs[1].sql, "USER_OBJECTS") || !strings.Contains(specs[1].sql, "OBJECT_TYPE = 'SEQUENCE'") {
|
||||
t.Fatalf("expected USER_OBJECTS fallback query, got %q", specs[1].sql)
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user