No db triggers support

Added an option 'no_db_trigger' on connection builder for disabled
the database triggers, like the ones when the client connect.

rsfbclient-core/src/connection.rs

@@ -37,6 +37,7 @@ pub trait FirebirdClientDbOps: Send {
  &mut self,
  config: &Self::AttachmentConfig,
  dialect: Dialect,
+ no_db_triggers: bool,
  ) -> Result<Self::DbHandle, FbError>;
 
  /// Disconnect from the database

rsfbclient-native/src/connection.rs

@@ -114,10 +114,16 @@ impl<T: LinkageMarker> FirebirdClientDbOps for NativeFbClient<T> {
  &mut self,
  config: &Self::AttachmentConfig,
  dialect: Dialect,
+ no_db_triggers: bool,
  ) -> Result<NativeDbHandle, FbError> {
- let (dpb, conn_string) = self.build_dpb(config, dialect);
+ let (mut dpb, conn_string) = self.build_dpb(config, dialect);
  let mut handle = 0;
 
+ if no_db_triggers {
+ dpb.extend(&[ibase::isc_dpb_no_db_triggers as u8, 1 as u8]);
+ dpb.extend(&[1 as u8]);
+ }
+
  unsafe {
  if self.ibase.isc_attach_database()(
  &mut self.status[0],

rsfbclient-rust/src/client.rs

@@ -86,6 +86,7 @@ impl FirebirdClientDbOps for RustFbClient {
  &mut self,
  config: &Self::AttachmentConfig,
  dialect: Dialect,
+ no_db_triggers: bool,
  ) -> Result<RustDbHandle, FbError> {
  let host = config.host.as_str();
  let port = config.port;
@@ -110,7 +111,8 @@ impl FirebirdClientDbOps for RustFbClient {
  )?,
  };
 
- let attach_result = conn.attach_database(db_name, user, pass, role, dialect);
+ let attach_result =
+ conn.attach_database(db_name, user, pass, role, dialect, no_db_triggers);
 
  // Put the connection back
  self.conn.replace(conn);
@@ -420,6 +422,7 @@ impl FirebirdWireConnection {
  pass: &str,
  role_name: Option<&str>,
  dialect: Dialect,
+ no_db_triggers: bool,
  ) -> Result<DbHandle, FbError> {
  self.socket.write_all(&attach(
  db_name,
@@ -429,6 +432,7 @@ impl FirebirdWireConnection {
  self.charset.clone(),
  role_name.clone(),
  dialect,
+ no_db_triggers,
  ))?;
  self.socket.flush()?;
 

rsfbclient-rust/src/wire.rs

@@ -140,8 +140,18 @@ pub fn attach(
  charset: Charset,
  role_name: Option<&str>,
  dialect: Dialect,
+ no_db_triggers: bool,
 ) -> Bytes {
- let dpb = build_dpb(user, pass, protocol, charset, None, role_name, dialect);
+ let dpb = build_dpb(
+ user,
+ pass,
+ protocol,
+ charset,
+ None,
+ role_name,
+ dialect,
+ no_db_triggers,
+ );
 
  let mut attach = BytesMut::with_capacity(16 + db_name.len() + dpb.len());
 
@@ -166,7 +176,9 @@ pub fn create(
  role_name: Option<&str>,
  dialect: Dialect,
 ) -> Bytes {
- let dpb = build_dpb(user, pass, protocol, charset, page_size, role_name, dialect);
+ let dpb = build_dpb(
+ user, pass, protocol, charset, page_size, role_name, dialect, false,
+ );
 
  let mut create = BytesMut::with_capacity(16 + db_name.len() + dpb.len());
 
@@ -189,6 +201,7 @@ fn build_dpb(
  page_size: Option<u32>,
  role_name: Option<&str>,
  dialect: Dialect,
+ no_db_triggers: bool,
 ) -> Bytes {
  let mut dpb = BytesMut::with_capacity(64);
 
@@ -215,6 +228,11 @@ fn build_dpb(
  dpb.extend(&[ibase::isc_dpb_sql_dialect as u8, 1 as u8]);
  dpb.extend(&[dialect as u8]);
 
+ if no_db_triggers {
+ dpb.extend(&[ibase::isc_dpb_no_db_triggers as u8, 1 as u8]);
+ dpb.extend(&[1 as u8]);
+ }
+
  match protocol {
  // Plaintext password
  ProtocolVersion::V10 => {

src/connection/builders/builder_native.rs

@@ -214,6 +214,12 @@ where
  self.conn_conf.transaction_conf = builder(&mut transaction_builder()).build();
  self
  }
+
+ /// Disabled the database triggers
+ pub fn no_db_triggers(&mut self) -> &mut Self {
+ self.conn_conf.no_db_triggers = true;
+ self
+ }
 }
 
 impl<A, B> NativeConnectionBuilder<A, B> {

src/connection/builders/builder_pure_rust.rs

@@ -106,6 +106,12 @@ impl PureRustConnectionBuilder {
  self
  }
 
+ /// Disabled the database triggers
+ pub fn no_db_triggers(&mut self) -> &mut Self {
+ self.0.no_db_triggers = true;
+ self
+ }
+
  /// Default transaction configuration
  pub fn transaction(&mut self, conf: TransactionConfiguration) -> &mut Self {
  self.0.transaction_conf = conf;

src/connection/mod.rs

@@ -60,6 +60,7 @@ pub trait FirebirdClientFactory {
 pub struct ConnectionConfiguration<A> {
  attachment_conf: A,
  dialect: Dialect,
+ no_db_triggers: bool,
  stmt_cache_size: usize,
  transaction_conf: TransactionConfiguration,
 }
@@ -71,6 +72,7 @@ impl<A: Default> Default for ConnectionConfiguration<A> {
  dialect: Dialect::D3,
  stmt_cache_size: 20,
  transaction_conf: TransactionConfiguration::default(),
+ no_db_triggers: false,
  }
  }
 }
@@ -107,7 +109,8 @@ impl<C: FirebirdClient> Connection<C> {
  mut cli: C,
  conf: &ConnectionConfiguration<C::AttachmentConfig>,
  ) -> Result<Connection<C>, FbError> {
- let handle = cli.attach_database(&conf.attachment_conf, conf.dialect)?;
+ let handle =
+ cli.attach_database(&conf.attachment_conf, conf.dialect, conf.no_db_triggers)?;
  let stmt_cache = StmtCache::new(conf.stmt_cache_size);
 
  Ok(Connection {

src/tests/connection.rs

@@ -309,4 +309,44 @@ mk_tests_default! {
 
  Ok(())
  }
+
+ #[test]
+ #[cfg(all(not(feature = "embedded_tests")))]
+ fn no_db_triggers() -> Result<(), FbError> {
+
+ let epoch = SystemTime::now()
+ .duration_since(SystemTime::UNIX_EPOCH)
+ .unwrap()
+ .as_nanos();
+
+ let mut conn = cbuilder()
+ .connect()?;
+
+ conn.execute(&format!("create table log_conn{} (id int);", epoch), ())?;
+
+ conn.execute(&format!("create trigger trig_conexao{0} on connect as begin insert into log_conn{0} (id) values (5); end", epoch), ())?;
+
+ conn.close()?;
+
+ let mut conn2 = cbuilder()
+ .no_db_triggers()
+ .connect()?;
+
+ let resp: Option<(i32,)> = conn2.query_first(&format!("select * from log_conn{}", epoch), ())?;
+ assert_eq!(None, resp);
+
+ conn2.close()?;
+
+ let mut conn3 = cbuilder()
+ .connect()?;
+
+ let resp: Option<(i32,)> = conn3.query_first(&format!("select * from log_conn{}", epoch), ())?;
+ assert_eq!(Some((5,)), resp);
+
+ conn3.execute(&format!("drop trigger trig_conexao{};", epoch), ()).ok();
+ conn3.execute(&format!("drop table log_conn{};", epoch), ()).ok();
+ conn3.close()?;
+
+ Ok(())
+ }
 }