Fixed blobs greater than 65535 bytes

rsfbclient-native/src/params.rs

@@ -244,15 +244,18 @@ fn binary_to_blob<T: IBase>(
     // Assert that the handle is valid
     debug_assert_ne!(handle, 0);
 
-    unsafe {
-        if ibase.isc_put_segment()(
-            &mut status[0],
-            &mut handle,
-            bytes.len() as u16,
-            bytes.as_ptr() as *mut std::os::raw::c_char,
-        ) != 0
-        {
-            return Err(status.as_error(ibase));
+    // Max segment size: 65535
+    for b in bytes.chunks(65535) {
+        unsafe {
+            if ibase.isc_put_segment()(
+                &mut status[0],
+                &mut handle,
+                b.len() as u16,
+                b.as_ptr() as *mut std::os::raw::c_char,
+            ) != 0
+            {
+                return Err(status.as_error(ibase));
+            }
         }
     }
 

src/tests/params.rs

@@ -244,7 +244,7 @@
 
         let rstr: Vec<u8> = rand::thread_rng()
             .sample_iter::<u8, _>(Standard)
-            .take(10000)
+            .take(1024 * 1024)
             .collect();
 
         conn.execute("DROP TABLE PBIGBLOBBIN", ()).ok();
@@ -261,7 +261,7 @@
 
         let rstr: String = rand::thread_rng()
             .sample_iter::<char, _>(Standard)
-            .take(10000)
+            .take(1024 * 1024)
             .collect();
 
         conn.execute("DROP TABLE PBIGBLOBTEXT", ()).ok();
@@ -284,7 +284,7 @@
 
         conn.execute(
             "insert into pdates (ref, a) values ('a', ?)",
             (NaiveDate::from_ymd(2009, 8, 7),),
         )?;
         let val_exists: Option<(i16,)> = conn.query_first(
             "select 1 from pdates where ref = 'a' and a = '2009-08-07'",
@@ -294,7 +294,7 @@
 
         conn.execute(
             "insert into pdates (ref, b) values ('b', ?)",
             (NaiveDate::from_ymd(2009, 8, 7).and_hms(11, 32, 25),),
         )?;
         let val_exists: Option<(i16,)> = conn.query_first(
             "select 1 from pdates where ref = 'b' and b = '2009-08-07 11:32:25'",
@@ -304,7 +304,7 @@
 
         conn.execute(
             "insert into pdates (ref, c) values ('c', ?)",
             (NaiveTime::from_hms(11, 22, 33),),
         )?;
         let val_exists: Option<(i16,)> = conn.query_first(
             "select 1 from pdates where ref = 'c' and c = '11:22:33'",

src/tests/row.rs

@@ -166,7 +166,7 @@
 
         let rvec: Vec<u8> = rand::thread_rng()
             .sample_iter(Standard)
-            .take(10000)
+            .take(1024 * 1024)
             .collect();
 
         conn.execute("DROP TABLE RBIGBLOBBIN", ()).ok();
@@ -187,7 +187,7 @@
 
         let rstr: String = rand::thread_rng()
             .sample_iter::<char, _>(Standard)
-            .take(10000)
+            .take(1024 * 1024)
             .collect();
 
         conn.execute("DROP TABLE RBIGBLOBTEXT", ()).ok();
@@ -224,7 +224,7 @@
                     (),
                 )?
                 .unwrap();
         assert_eq!(NaiveDate::from_ymd(2010, 10, 10), a);
         assert_eq!(NaiveDate::from_ymd(2010, 10, 10).and_hms(10, 10, 10), b);
         assert_eq!(NaiveTime::from_hms(10, 10, 10), c);