This commit is contained in:
OMGeeky
2023-06-03 13:38:24 +02:00
parent 1380a56b8b
commit 3109712a8c
6 changed files with 13 additions and 13 deletions

View File

@@ -1,11 +1,11 @@
use std::error::Error;
use std::fmt::Debug;
use google_bigquery2::client::NoToken;
use google_bigquery2::hyper::client::HttpConnector;
use google_bigquery2::hyper_rustls::HttpsConnector;
use google_bigquery2::Bigquery;
use google_bigquery2::{hyper, hyper_rustls, oauth2};
use google_bigquery2::client::NoToken;
#[derive(Clone)]
pub struct BigqueryClient {

View File

@@ -1,10 +1,10 @@
use std::collections::HashMap;
use std::fmt::Debug;
use crate::prelude::*;
use async_trait::async_trait;
pub use google_bigquery2::api::QueryParameter;
pub use google_bigquery2::api::{QueryParameterType, QueryParameterValue};
use crate::prelude::*;
use serde_json::Value;
use crate::client::BigqueryClient;

View File

@@ -3,9 +3,9 @@ use std::error::Error;
use std::fmt::{Debug, Display, Formatter};
use std::marker::PhantomData;
use crate::prelude::*;
use google_bigquery2::api::{ErrorProto, QueryParameter, QueryRequest};
use google_bigquery2::hyper::{Body, Response};
use crate::prelude::*;
use serde_json::Value;
use crate::data::param_conversion::BigDataValueType;

View File

@@ -7,4 +7,4 @@ pub mod re_exports {
pub use async_trait;
pub use log;
pub use serde_json;
}
}

View File

@@ -6,8 +6,8 @@ pub use crate::data::{BigQueryTable, BigQueryTableBase, OrderDirection};
pub type Result<T> = std::result::Result<T, Box<dyn std::error::Error + Send + Sync>>;
#[cfg(not(feature = "tracing"))]
pub use log::{trace, info, warn, error, debug};
pub use log::{debug, error, info, trace, warn};
#[cfg(feature = "tracing")]
pub use tracing::{trace, info, warn, error, debug};
pub use tracing::{debug, error, info, trace, warn};
pub use log::LevelFilter;
pub use log::LevelFilter;

View File

@@ -12,13 +12,13 @@ pub struct DbInfos {
#[primary_key]
#[db_name("Id")]
row_id: i64,
info1: Option::<String>,
info1: Option<String>,
#[db_name("info")]
info2: Option::<String>,
info3: Option::<String>,
info4i: Option::<i32>,
info2: Option<String>,
info3: Option<String>,
info4i: Option<i32>,
#[db_name("yes")]
info4b: Option::<bool>,
info4b: Option<bool>,
}
#[tokio::test]
@@ -218,7 +218,7 @@ async fn test_select_limit_1() {
}
#[test]
fn test_empty_client(){
fn test_empty_client() {
let empty_client = BigqueryClient::empty();
debug!("empty client: {:?}", empty_client);
}