forked from TIBCOSoftware/flogo-contrib
-
Notifications
You must be signed in to change notification settings - Fork 2
/
activity_test.go
executable file
·89 lines (73 loc) · 2.13 KB
/
activity_test.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
package databasequery
import (
"fmt"
"github.com/TIBCOSoftware/flogo-contrib/action/flow/test"
"github.com/TIBCOSoftware/flogo-lib/core/activity"
"io/ioutil"
"testing"
)
var activityMetadata *activity.Metadata
func getActivityMetadata() *activity.Metadata {
if activityMetadata == nil {
jsonMetadataBytes, err := ioutil.ReadFile("activity.json")
if err != nil {
panic("No Json Metadata found for activity.json path")
}
activityMetadata = activity.NewMetadata(string(jsonMetadataBytes))
}
return activityMetadata
}
func TestCreate(t *testing.T) {
act := NewActivity(getActivityMetadata())
if act == nil {
t.Error("Activity Not Created")
t.Fail()
return
}
}
//debugging
func TestEval(t *testing.T) {
defer func() {
if r := recover(); r != nil {
t.Failed()
t.Errorf("panic during execution: %v", r)
}
}()
act := NewActivity(getActivityMetadata())
tc := test.NewTestActivityContext(getActivityMetadata())
//setup attr for mysql
fmt.Println("===============================")
fmt.Println("Unit Test ===> MySQL Connection")
fmt.Println("===============================")
fmt.Println("")
tc.SetInput("driverName", "mysql")
tc.SetInput("datasourceName", "flogo:password@tcp(localhost:3306)/testdb")
tc.SetInput("query", "select * from person")
/*
//setup attr for sqlite3
fmt.Println("===============================")
fmt.Println("Unit Test ===> SQLITE3 Connection")
fmt.Println("===============================")
fmt.Println("")
tc.SetInput("driverName", "sqlite3")
tc.SetInput("datasourceName", "akashdb")
tc.SetInput("query", "select * from person")
*/
/*
//setup attr for postgres
fmt.Println("===============================")
fmt.Println("Unit Test ===> POSTGRES Connection")
fmt.Println("===============================")
fmt.Println("")
tc.SetInput("driverName", "postgres")
tc.SetInput("datasourceName", "host=localhost port=5432 user=postgres password=mysecretpassword dbname=postgres sslmode=disable")
tc.SetInput("query", "select * from company")
*/
act.Eval(tc)
//check result attr
result := tc.GetOutput("result")
fmt.Println("result: ", result)
if result == nil {
t.Fail()
}
}