/
Connection.purs
141 lines (124 loc) · 2.74 KB
/
Connection.purs
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
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
module MySQL.Connection
( ConnectionInfo
, QueryOptions
, Connection
, defaultConnectionInfo
, queryWithOptions
, queryWithOptions_
, query
, query_
, execute
, execute_
, _query
, format
, createConnection
, closeConnection
) where
import Prelude
import Data.Either (either)
import Data.Function.Uncurried (Fn3, runFn3)
import Data.Time.Duration (Milliseconds(..))
import Effect (Effect)
import Effect.Aff (Aff)
import Effect.Aff.Compat (EffectFnAff, fromEffectFnAff)
import Foreign (Foreign)
import MySQL.Internal (liftError)
import MySQL.QueryValue (QueryValue)
import Simple.JSON (class ReadForeign, read)
type ConnectionInfo =
{ host :: String
, port :: Int
, user :: String
, password :: String
, database :: String
, charset :: String
, timezone :: String
, connectTimeout :: Milliseconds
, dateStrings :: Boolean
, debug :: Boolean
, trace :: Boolean
, multipleStatements :: Boolean
}
type QueryOptions =
{ sql :: String
, nestTables :: Boolean
}
foreign import data Connection :: Type
defaultConnectionInfo :: ConnectionInfo
defaultConnectionInfo =
{ host: "localhost"
, port: 3306
, user: "root"
, password: ""
, database: ""
, charset: "UTF8_GENERAL_CI"
, timezone: "Z"
, connectTimeout: Milliseconds 10000.0
, dateStrings: true
, debug: false
, trace: true
, multipleStatements : false
}
queryWithOptions
:: forall a
. ReadForeign a
=> QueryOptions
-> Array QueryValue
-> Connection
-> Aff (Array a)
queryWithOptions opts vs conn = do
rows <- _query opts vs conn
either liftError pure $ read rows
queryWithOptions_
:: forall a
. ReadForeign a
=> QueryOptions
-> Connection
-> Aff (Array a)
queryWithOptions_ opts = queryWithOptions opts []
query
:: forall a
. ReadForeign a
=> String
-> Array QueryValue
-> Connection
-> Aff (Array a)
query sql = queryWithOptions { sql, nestTables: false }
query_
:: forall a
. ReadForeign a
=> String
-> Connection
-> Aff (Array a)
query_ sql = query sql []
execute
:: String
-> Array QueryValue
-> Connection
-> Aff Unit
execute sql vs conn =
void $ _query { sql, nestTables: false } vs conn
execute_
:: String
-> Connection
-> Aff Unit
execute_ sql = execute sql []
_query
:: QueryOptions
-> Array QueryValue
-> Connection
-> Aff Foreign
_query opts values conn = fromEffectFnAff $ runFn3 _queryImpl opts values conn
foreign import createConnection
:: ConnectionInfo
-> Effect Connection
foreign import closeConnection
:: Connection
-> Effect Unit
foreign import _queryImpl
:: Fn3 QueryOptions (Array QueryValue) Connection (EffectFnAff Foreign)
foreign import format
:: String
-> Array QueryValue
-> Connection
-> Effect String