#[cfg(test)]
mod tests {
	use tiberius_mssql_broker::config::SqlConfig;
	use tiberius_mssql_broker::connection::{client, LongPooling};

	fn config() -> SqlConfig {
		let config = SqlConfig {
			host: ".".to_string(),
			instance: Some("SQLEXPRESS".to_string()),
			port: 1433,
			username: "sa".to_string(),
			password: "julfikar123@".to_string(),
			database: "AED_MOBILE".to_string(),
			trust_cert: true,
			allow_encrypt: true,
			max_pool: 1,
			sql_browser: false,
		};
		config
	}

	#[tokio::test]
	async fn simple_connect() {
		let config = config();

		let conn = client(&config).await;
		assert!(conn.is_ok(),"{:?}",conn.err());

		let mut conn = conn.unwrap();

		let res = conn.simple_query("select * from IV;").await;
		assert!(res.is_ok(),"{:?}",res.err());
	}

	#[tokio::test]
	async fn pooling_connect() {
		let config = config();

		let pool = LongPooling::new(&config);
		assert!(pool.is_ok(),"{:?}",pool.err());

		let pool = pool.unwrap();
		let client = pool.client().await;
		assert!(client.is_ok(),"{:?}",client.err());
	}

	#[tokio::test]
	async fn query() {
		let config = config();

		let pool = LongPooling::new(&config);
		assert!(pool.is_ok(),"{:?}",pool.err());

		let pool = pool.unwrap();
		let client = pool.client().await;
		assert!(client.is_ok(),"{:?}",client.err());

		let mut client = client.unwrap();
		let res = client.simple_query(r#"
			SELECT * FROM IV;
		"#).await;

		let res = res.unwrap();
		let rows = res.into_results().await;
		assert!(rows.is_ok(),"{:?}",rows.err());

		let rows = rows.unwrap();
		assert!(rows.len() > 0);
	}
}