1use crate::{ffi, Connection, Result};
4use std::ffi::c_int;
5
6#[derive(Copy, Clone, Debug)]
13#[repr(i32)]
14#[non_exhaustive]
15#[expect(non_camel_case_types)]
16pub enum Limit {
17 SQLITE_LIMIT_LENGTH = ffi::SQLITE_LIMIT_LENGTH,
19 SQLITE_LIMIT_SQL_LENGTH = ffi::SQLITE_LIMIT_SQL_LENGTH,
21 SQLITE_LIMIT_COLUMN = ffi::SQLITE_LIMIT_COLUMN,
25 SQLITE_LIMIT_EXPR_DEPTH = ffi::SQLITE_LIMIT_EXPR_DEPTH,
27 SQLITE_LIMIT_COMPOUND_SELECT = ffi::SQLITE_LIMIT_COMPOUND_SELECT,
29 SQLITE_LIMIT_VDBE_OP = ffi::SQLITE_LIMIT_VDBE_OP,
32 SQLITE_LIMIT_FUNCTION_ARG = ffi::SQLITE_LIMIT_FUNCTION_ARG,
34 SQLITE_LIMIT_ATTACHED = ffi::SQLITE_LIMIT_ATTACHED,
36 SQLITE_LIMIT_LIKE_PATTERN_LENGTH = ffi::SQLITE_LIMIT_LIKE_PATTERN_LENGTH,
39 SQLITE_LIMIT_VARIABLE_NUMBER = ffi::SQLITE_LIMIT_VARIABLE_NUMBER,
41 SQLITE_LIMIT_TRIGGER_DEPTH = ffi::SQLITE_LIMIT_TRIGGER_DEPTH,
43 SQLITE_LIMIT_WORKER_THREADS = ffi::SQLITE_LIMIT_WORKER_THREADS,
46 SQLITE_LIMIT_PARSER_DEPTH = 12, #[cfg(test)]
50 INVALID = -1,
51}
52
53impl Connection {
54 #[inline]
56 pub fn limit(&self, limit: Limit) -> Result<i32> {
57 let c = self.db.borrow();
58 let rc = unsafe { ffi::sqlite3_limit(c.db(), limit as c_int, -1) };
59 if rc < 0 {
60 return Err(err!(ffi::SQLITE_RANGE, "{limit:?} is invalid"));
61 }
62 Ok(rc)
63 }
64
65 #[inline]
68 pub fn set_limit(&self, limit: Limit, new_val: i32) -> Result<i32> {
69 if new_val < 0 {
70 return Err(err!(ffi::SQLITE_RANGE, "{new_val} is invalid"));
71 }
72 let c = self.db.borrow_mut();
73 let rc = unsafe { ffi::sqlite3_limit(c.db(), limit as c_int, new_val) };
74 if rc < 0 {
75 return Err(err!(ffi::SQLITE_RANGE, "{limit:?} is invalid"));
76 }
77 Ok(rc)
78 }
79}
80
81#[cfg(test)]
82mod test {
83 #[cfg(all(target_family = "wasm", target_os = "unknown"))]
84 use wasm_bindgen_test::wasm_bindgen_test as test;
85
86 use super::*;
87 use crate::Result;
88
89 #[test]
90 fn test_limit_values() {
91 assert_eq!(Limit::SQLITE_LIMIT_LENGTH as i32, ffi::SQLITE_LIMIT_LENGTH,);
92 assert_eq!(
93 Limit::SQLITE_LIMIT_SQL_LENGTH as i32,
94 ffi::SQLITE_LIMIT_SQL_LENGTH,
95 );
96 assert_eq!(Limit::SQLITE_LIMIT_COLUMN as i32, ffi::SQLITE_LIMIT_COLUMN,);
97 assert_eq!(
98 Limit::SQLITE_LIMIT_EXPR_DEPTH as i32,
99 ffi::SQLITE_LIMIT_EXPR_DEPTH,
100 );
101 assert_eq!(
102 Limit::SQLITE_LIMIT_COMPOUND_SELECT as i32,
103 ffi::SQLITE_LIMIT_COMPOUND_SELECT,
104 );
105 assert_eq!(
106 Limit::SQLITE_LIMIT_VDBE_OP as i32,
107 ffi::SQLITE_LIMIT_VDBE_OP,
108 );
109 assert_eq!(
110 Limit::SQLITE_LIMIT_FUNCTION_ARG as i32,
111 ffi::SQLITE_LIMIT_FUNCTION_ARG,
112 );
113 assert_eq!(
114 Limit::SQLITE_LIMIT_ATTACHED as i32,
115 ffi::SQLITE_LIMIT_ATTACHED,
116 );
117 assert_eq!(
118 Limit::SQLITE_LIMIT_LIKE_PATTERN_LENGTH as i32,
119 ffi::SQLITE_LIMIT_LIKE_PATTERN_LENGTH,
120 );
121 assert_eq!(
122 Limit::SQLITE_LIMIT_VARIABLE_NUMBER as i32,
123 ffi::SQLITE_LIMIT_VARIABLE_NUMBER,
124 );
125 assert_eq!(
126 Limit::SQLITE_LIMIT_TRIGGER_DEPTH as i32,
127 ffi::SQLITE_LIMIT_TRIGGER_DEPTH,
128 );
129 assert_eq!(
130 Limit::SQLITE_LIMIT_WORKER_THREADS as i32,
131 ffi::SQLITE_LIMIT_WORKER_THREADS,
132 );
133 }
134
135 #[test]
136 #[cfg_attr(miri, ignore)]
137 fn test_limit() -> Result<()> {
138 let db = Connection::open_in_memory()?;
139 db.set_limit(Limit::SQLITE_LIMIT_LENGTH, 1024)?;
140 assert_eq!(1024, db.limit(Limit::SQLITE_LIMIT_LENGTH)?);
141
142 db.set_limit(Limit::SQLITE_LIMIT_SQL_LENGTH, 1024)?;
143 assert_eq!(1024, db.limit(Limit::SQLITE_LIMIT_SQL_LENGTH)?);
144
145 db.set_limit(Limit::SQLITE_LIMIT_COLUMN, 64)?;
146 assert_eq!(64, db.limit(Limit::SQLITE_LIMIT_COLUMN)?);
147
148 db.set_limit(Limit::SQLITE_LIMIT_EXPR_DEPTH, 256)?;
149 assert_eq!(256, db.limit(Limit::SQLITE_LIMIT_EXPR_DEPTH)?);
150
151 db.set_limit(Limit::SQLITE_LIMIT_COMPOUND_SELECT, 32)?;
152 assert_eq!(32, db.limit(Limit::SQLITE_LIMIT_COMPOUND_SELECT)?);
153
154 db.set_limit(Limit::SQLITE_LIMIT_FUNCTION_ARG, 32)?;
155 assert_eq!(32, db.limit(Limit::SQLITE_LIMIT_FUNCTION_ARG)?);
156
157 db.set_limit(Limit::SQLITE_LIMIT_ATTACHED, 2)?;
158 assert_eq!(2, db.limit(Limit::SQLITE_LIMIT_ATTACHED)?);
159
160 db.set_limit(Limit::SQLITE_LIMIT_LIKE_PATTERN_LENGTH, 128)?;
161 assert_eq!(128, db.limit(Limit::SQLITE_LIMIT_LIKE_PATTERN_LENGTH)?);
162
163 db.set_limit(Limit::SQLITE_LIMIT_VARIABLE_NUMBER, 99)?;
164 assert_eq!(99, db.limit(Limit::SQLITE_LIMIT_VARIABLE_NUMBER)?);
165
166 db.set_limit(Limit::SQLITE_LIMIT_TRIGGER_DEPTH, 32)?;
167 assert_eq!(32, db.limit(Limit::SQLITE_LIMIT_TRIGGER_DEPTH)?);
168
169 db.set_limit(Limit::SQLITE_LIMIT_WORKER_THREADS, 2)?;
170 #[cfg(not(all(target_family = "wasm", target_os = "unknown")))]
171 assert_eq!(2, db.limit(Limit::SQLITE_LIMIT_WORKER_THREADS)?);
172
173 #[cfg(all(target_family = "wasm", target_os = "unknown"))]
176 assert_eq!(0, db.limit(Limit::SQLITE_LIMIT_WORKER_THREADS)?);
177
178 assert!(db
179 .set_limit(Limit::SQLITE_LIMIT_WORKER_THREADS, -1)
180 .is_err());
181 assert!(db.set_limit(Limit::INVALID, 0).is_err());
182 assert!(db.limit(Limit::INVALID).is_err());
183 Ok(())
184 }
185}