@@ -797,6 +797,9 @@ private function get($query, $db = null)
797
797
// bind WHERE values
798
798
if (!empty ($ where_values ) && count ($ where_values ) > 0 ) {
799
799
foreach ($ where_values as $ key => $ value ) {
800
+ if (is_string ($ value ) && strtolower ($ value ) === 'null ' ) {
801
+ $ value = null ;
802
+ }
800
803
$ type = self ::detectPDOType ($ value );
801
804
$ key = ': ' . $ key ;
802
805
$ sql_compiled = preg_replace ('/( ' . preg_quote ($ key , '/ ' ) . ")([,]|\s|$|\))/i " , "' " . $ value . "'$2 " , $ sql_compiled );
@@ -807,6 +810,9 @@ private function get($query, $db = null)
807
810
// bind JOIN values
808
811
if (!empty ($ join_values ) && count ($ join_values ) > 0 ) {
809
812
foreach ($ join_values as $ key => $ value ) {
813
+ if (is_string ($ value ) && strtolower ($ value ) === 'null ' ) {
814
+ $ value = null ;
815
+ }
810
816
$ type = self ::detectPDOType ($ value );
811
817
$ key = ': ' . $ key ;
812
818
$ sql_compiled = preg_replace ('/( ' . preg_quote ($ key , '/ ' ) . ")([,]|\s|$|\))/i " , "' " . $ value . "'$2 " , $ sql_compiled );
@@ -1067,9 +1073,13 @@ private function patch($query, $db = null)
1067
1073
// bind WHERE values
1068
1074
if (!empty ($ where_values ) && count ($ where_values ) > 0 ) {
1069
1075
foreach ($ where_values as $ key => $ value ) {
1076
+ if (is_string ($ value ) && strtolower ($ value ) === 'null ' ) {
1077
+ $ value = null ;
1078
+ }
1079
+ $ type = self ::detectPDOType ($ value );
1070
1080
$ key = ': ' . $ key ;
1071
1081
$ sql_compiled = self ::debugCompileSQL ($ sql_compiled , $ key , $ value );
1072
- $ sth ->bindValue ($ key , $ value );
1082
+ $ sth ->bindValue ($ key , $ value, $ type );
1073
1083
}
1074
1084
}
1075
1085
0 commit comments