@@ -358,7 +358,7 @@ mysql-driver: make object! [
358
358
]
359
359
360
360
set 'sql-escape func [value [string! ] /local c][
361
- parse/all value [
361
+ parse value [
362
362
any [
363
363
c: sql-chars (c: change/part c select escaped c/1 1 ) :c
364
364
| sql-no-chars
@@ -694,7 +694,7 @@ mysql-driver: make object! [
694
694
695
695
insert-all-queries : func [ port [port! ] data [string! ] /local s e res d] [
696
696
d: port/extra/delimiter
697
- parse/all s: data [
697
+ parse s: data [
698
698
any [
699
699
#"#" thru newline
700
700
| #"'" any ["\\" | "\'" | "''" | not-squote] #"'"
@@ -769,7 +769,7 @@ mysql-driver: make object! [
769
769
254 [
770
770
if pl/packet-len < 9 [
771
771
if pl/packet-len = 5 [
772
- parse/all/ case next port/data [
772
+ parse/case next port/data [
773
773
read-int (pl/current-result/warnings: int)
774
774
read-int (pl/more-results?: not zero? int and 8 )
775
775
]
@@ -791,7 +791,7 @@ mysql-driver: make object! [
791
791
]
792
792
]
793
793
; ignore session track info
794
- parse/all/ case next port/data rules
794
+ parse/case next port/data rules
795
795
]
796
796
return 'OK
797
797
]
@@ -905,7 +905,7 @@ mysql-driver: make object! [
905
905
case [
906
906
any [pl/current-cmd = defs/cmd/query
907
907
pl/current-cmd = defs/cmd/field-list ][
908
- parse/all/ case buf [
908
+ parse/case buf [
909
909
read-length (if zero? pl/current-result/n-columns: len [
910
910
pl/stream-end?: true
911
911
sys/log/more 'MySQL["stream ended because of 0 columns" ]
@@ -970,7 +970,7 @@ mysql-driver: make object! [
970
970
OTHER [
971
971
col: make column-class []
972
972
either pl/capabilities and defs/client/protocol-41 [
973
- parse/all/ case buf [
973
+ parse/case buf [
974
974
read-field (col/catalog: to string! field)
975
975
read-field (col/db: to string! field)
976
976
read-field (col/table: to string! field)
@@ -987,7 +987,7 @@ mysql-driver: make object! [
987
987
read-length (col/default: len)
988
988
]
989
989
][
990
- parse/all/ case buf [
990
+ parse/case buf [
991
991
read-field (col/table: to string! field)
992
992
read-field (col/name: to string! field)
993
993
read-length (col/length: len)
@@ -1049,7 +1049,7 @@ mysql-driver: make object! [
1049
1049
OTHER FB[
1050
1050
row: make block! pl/current-result/n-columns
1051
1051
;sys/log/more 'MySQL["row buf:" copy/part buf pl/next-packet-length]
1052
- parse/all/ case buf [pl/current-result/n-columns [read-field (append row field)]]
1052
+ parse/case buf [pl/current-result/n-columns [read-field (append row field)]]
1053
1053
;sys/log/more 'MySQL["row:" mold row]
1054
1054
if none? pl/current-result/rows [
1055
1055
pl/current-result/rows: make block! 10
@@ -1114,13 +1114,13 @@ mysql-driver: make object! [
1114
1114
tcp-port: port
1115
1115
pl: port/extra
1116
1116
if data/1 = 255 [;error packet
1117
- parse/all skip data 1 [
1117
+ parse skip data 1 [
1118
1118
read-int (pl/error-code: int)
1119
1119
read-string (pl/error-msg: string)
1120
1120
]
1121
1121
cause-error 'Access 'message reduce [pl/error-code pl/error-msg ]
1122
1122
]
1123
- parse/all data [
1123
+ parse data [
1124
1124
read-byte (pl/protocol: byte)
1125
1125
read-string (pl/version: string)
1126
1126
read-long (pl/thread-id: long)
@@ -1255,7 +1255,7 @@ mysql-driver: make object! [
1255
1255
switch /default pl/packet-state [
1256
1256
reading-packet-head [
1257
1257
;sys/log/more 'MySQL["read a packet head" mold copy/part tcp-port/data std-header-length]
1258
- parse/all tcp-port/data [
1258
+ parse tcp-port/data [
1259
1259
read-int24 (pl/packet-len: int24)
1260
1260
read-byte (pl/seq-num: byte)
1261
1261
]
0 commit comments