-
Notifications
You must be signed in to change notification settings - Fork 436
/
request.coffee
106 lines (79 loc) · 2.79 KB
/
request.coffee
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
EventEmitter = require('events').EventEmitter
TYPES = require('./data-type').typeByName
class Request extends EventEmitter
constructor: (@sqlTextOrProcedure, @callback) ->
@parameters = []
@parametersByName = {}
@userCallback = @callback
@callback = ->
if @preparing
@emit('prepared')
@preparing = false
else
@userCallback.apply(@, arguments)
addParameter: (name, type, value, options) ->
if arguments.length < 4
if typeof value == 'object' && !(value instanceof Date)
options = value
value = undefined
options ||= {}
parameter =
type: type
name: name
value: value
output: options.output ||= false
length: options.length
@parameters.push(parameter)
@parametersByName[name] = parameter
addOutputParameter: (name, type, value, options) ->
if arguments.length < 4
if typeof value == 'object' && !(value instanceof Date)
options = value
value = undefined
options ||= {}
options.output = true
@addParameter(name, type, value, options)
makeParamsParameter: (parameters) ->
paramsParameter = ''
for parameter in parameters
if paramsParameter.length > 0
paramsParameter += ', '
paramsParameter += "@#{parameter.name} "
paramsParameter += parameter.type.declaration(parameter)
if parameter.output
paramsParameter += ' OUTPUT'
paramsParameter
transformIntoExecuteSqlRpc: () ->
@originalParameters = @parameters
@parameters = []
@addParameter('statement', TYPES.NVarChar, @sqlTextOrProcedure)
@addParameter('params', TYPES.NVarChar, @makeParamsParameter(@originalParameters))
for parameter in @originalParameters
@parameters.push(parameter)
@sqlTextOrProcedure = 'sp_executesql'
transformIntoPrepareRpc: () ->
@originalParameters = @parameters
@parameters = []
@addOutputParameter('handle', TYPES.Int)
@addParameter('params', TYPES.NVarChar, @makeParamsParameter(@originalParameters))
@addParameter('stmt', TYPES.NVarChar, @sqlTextOrProcedure)
@sqlTextOrProcedure = 'sp_prepare'
@preparing = true
@on('returnValue', (name, value, metadata) ->
if (name == 'handle')
@handle = value
else
throw new Error("Unexpected output parameter #{name} from sp_prepare")
)
transformIntoUnprepareRpc: (parameters) ->
@parameters = []
@addParameter('handle', TYPES.Int, @handle)
@sqlTextOrProcedure = 'sp_unprepare'
transformIntoExecuteRpc: (parameters) ->
@parameters = []
@addParameter('handle', TYPES.Int, @handle)
for parameter in @originalParameters
parameter.value = parameters[parameter.name]
@parameters.push(parameter)
@sqlTextOrProcedure = 'sp_execute'
module.exports = Request