[WIP] Initial support of table function

Cargo.toml

@@ -51,6 +51,8 @@ arrow = { version = "29", default-features = false, features = ["prettyprint", "
 rust_decimal = "1.14"
 strum = { version = "0.24", features = ["derive"] }
 r2d2 = { version = "0.8.9", optional = true }
+num-derive = { version = "0.3.3" }
+num-traits = { version = "0.2.15" }
 
 [dev-dependencies]
 doc-comment = "0.3"

src/inner_connection.rs

@@ -9,6 +9,7 @@ use super::{Appender, Config, Connection, Result};
 use crate::error::{result_from_duckdb_appender, result_from_duckdb_arrow, result_from_duckdb_prepare, Error};
 use crate::raw_statement::RawStatement;
 use crate::statement::Statement;
+use crate::table_function::TableFunction;
 
 pub struct InnerConnection {
     pub db: ffi::duckdb_database,
@@ -88,6 +89,14 @@ impl InnerConnection {
         Ok(Statement::new(conn, unsafe { RawStatement::new(c_stmt) }))
     }
 
+    pub fn register_table_funcion(&mut self, table_function: TableFunction) -> Result<()> {
+        unsafe {
+            // FIXME
+            let _ = ffi::duckdb_register_table_function(self.con, table_function.ptr);
+        }
+        Ok(())
+    }
+
     pub fn appender<'a>(&mut self, conn: &'a Connection, table: &str, schema: &str) -> Result<Appender<'a>> {
         let mut c_app: ffi::duckdb_appender = ptr::null_mut();
         let c_table = CString::new(table).unwrap();

src/lib.rs

@@ -108,8 +108,12 @@ mod row;
 mod statement;
 mod transaction;
 
+/// The duckdb table function interface
+pub mod table_function;
 pub mod types;
 
+use table_function::TableFunction;
+
 pub(crate) mod util;
 
 // Number of cached prepared statements we'll hold on to.
@@ -512,6 +516,12 @@ impl Connection {
         self.db.borrow().is_autocommit()
     }
 
+    /// Register the given TableFunction with the current db
+    #[inline]
+    pub fn register_table_function(&self, table_function: TableFunction) -> Result<()> {
+        self.db.borrow_mut().register_table_funcion(table_function)
+    }
+
     /// Creates a new connection to the already-opened database.
     pub fn try_clone(&self) -> Result<Self> {
         let inner = self.db.borrow().try_clone()?;

src/row.rs

@@ -304,7 +304,7 @@ impl<'stmt> Row<'stmt> {
                 Error::InvalidColumnType(idx, self.stmt.column_name_unwrap(idx).into(), value.data_type())
             }
             FromSqlError::OutOfRange(i) => Error::IntegralValueOutOfRange(idx, i),
-            FromSqlError::Other(err) => Error::FromSqlConversionFailure(idx as usize, value.data_type(), err),
+            FromSqlError::Other(err) => Error::FromSqlConversionFailure(idx, value.data_type(), err),
             #[cfg(feature = "uuid")]
             FromSqlError::InvalidUuidSize(_) => {
                 Error::InvalidColumnType(idx, self.stmt.column_name_unwrap(idx).into(), value.data_type())