Copyright	(c) Soostone Inc 2020
License	AllRightsReserved
Stability	experimental
Portability	POSIX
Safe Haskell	None
Language	Haskell2010

Napkin.Run.BigQuery

Contents

Orphan instances

Description

Synopsis

data BigQueryRunError
- = ProtoErrors !(NonEmpty ErrorProto)
- | MissingDatasetId
data family BackendConn b
data family BackendSchemaField bk
mkBigQueryEnv :: (MonadCatch m, Katip m) => Maybe FilePath -> DbBackendOptions BigQuery -> BQProjectId -> Maybe BQDataSetId -> m (BackendConn BigQuery)
mkBigQueryEnv' :: (MonadCatch m, MonadIO m) => Natural -> IO GoogleEnv -> BQProjectId -> Maybe BQDataSetId -> Labels -> m (BackendConn BigQuery)
mkBigQueryEnvWithCredentials :: (MonadCatch m, Katip m) => Maybe ByteString -> Credentials BigQueryScopes -> DbBackendOptions BigQuery -> BQProjectId -> Maybe BQDataSetId -> m (BackendConn BigQuery)
mkBigQueryEnvWithJsonCredentials :: (MonadCatch m, Katip m) => Maybe ByteString -> CredentialsJson -> DbBackendOptions BigQuery -> BQProjectId -> Maybe BQDataSetId -> m (BackendConn BigQuery)
mkBigQueryEnvWithCredentialsFile :: (MonadCatch m, Katip m) => FilePath -> DbBackendOptions BigQuery -> BQProjectId -> Maybe BQDataSetId -> m (BackendConn BigQuery)

Documentation

data BigQueryRunError #

Constructors

ProtoErrors !(NonEmpty ErrorProto)
MissingDatasetId

Instances

Instances details

Eq BigQueryRunError #
Instance details Defined in Napkin.Run.BigQuery.Types Methods (==) :: BigQueryRunError -> BigQueryRunError -> Bool # (/=) :: BigQueryRunError -> BigQueryRunError -> Bool #
Show BigQueryRunError #
Instance details Defined in Napkin.Run.BigQuery.Types Methods showsPrec :: Int -> BigQueryRunError -> ShowS # show :: BigQueryRunError -> String # showList :: [BigQueryRunError] -> ShowS #
Exception BigQueryRunError #
Instance details Defined in Napkin.Run.BigQuery.Types Methods toException :: BigQueryRunError -> SomeException # fromException :: SomeException -> Maybe BigQueryRunError # displayException :: BigQueryRunError -> String #

data family BackendConn b #

Instances

Instances details

data BackendConn Sqlite #
Instance details Defined in Napkin.Run.Sqlite data BackendConn Sqlite = SqliteConn (Pool Connection)
data BackendConn Redshift #
Instance details Defined in Napkin.Run.Redshift data BackendConn Redshift = RedshiftConn (Pool Connection)
data BackendConn Postgres #
Instance details Defined in Napkin.Run.Postgres data BackendConn Postgres = PostgresConn { getPostgresConn :: Pool Connection }
data BackendConn BigQuery #
Instance details Defined in Napkin.Run.BigQuery data BackendConn BigQuery = BigQueryEnv { bqeEnv :: Pool GoogleEnv bqeProjectId :: BQProjectId bqeDatasetId :: Maybe BQDataSetId bqeJobLabels :: Labels }

data family BackendSchemaField bk #

Instances

Instances details

Command GetRelationSchema [BackendSchemaField Sqlite] Sqlite #
Instance details Defined in Napkin.Run.Sqlite Methods execCommand :: (Katip m, MonadQueryStats m) => BackendConn Sqlite -> GetRelationSchema -> m [BackendSchemaField Sqlite] #
Command GetRelationSchema [BackendSchemaField Redshift] Redshift #
Instance details Defined in Napkin.Run.Redshift Methods execCommand :: (Katip m, MonadQueryStats m) => BackendConn Redshift -> GetRelationSchema -> m [BackendSchemaField Redshift] #
Command GetRelationSchema [BackendSchemaField Postgres] Postgres #
Instance details Defined in Napkin.Run.Postgres Methods execCommand :: (Katip m, MonadQueryStats m) => BackendConn Postgres -> GetRelationSchema -> m [BackendSchemaField Postgres] #
Command GetRelationSchema [BackendSchemaField BigQuery] BigQuery #
Instance details Defined in Napkin.Run.BigQuery Methods execCommand :: (Katip m, MonadQueryStats m) => BackendConn BigQuery -> GetRelationSchema -> m [BackendSchemaField BigQuery] #
Eq (BackendSchemaField Sqlite) #
Instance details Defined in Napkin.Run.Sqlite Methods (==) :: BackendSchemaField Sqlite -> BackendSchemaField Sqlite -> Bool # (/=) :: BackendSchemaField Sqlite -> BackendSchemaField Sqlite -> Bool #
Eq (BackendSchemaField Redshift) #
Instance details Defined in Napkin.Run.Redshift Methods (==) :: BackendSchemaField Redshift -> BackendSchemaField Redshift -> Bool # (/=) :: BackendSchemaField Redshift -> BackendSchemaField Redshift -> Bool #
Eq (BackendSchemaField Postgres) #
Instance details Defined in Napkin.Run.Postgres Methods (==) :: BackendSchemaField Postgres -> BackendSchemaField Postgres -> Bool # (/=) :: BackendSchemaField Postgres -> BackendSchemaField Postgres -> Bool #
Eq (BackendSchemaField BigQuery) #
Instance details Defined in Napkin.Run.BigQuery Methods (==) :: BackendSchemaField BigQuery -> BackendSchemaField BigQuery -> Bool # (/=) :: BackendSchemaField BigQuery -> BackendSchemaField BigQuery -> Bool #
Show (BackendSchemaField Sqlite) #
Instance details Defined in Napkin.Run.Sqlite Methods showsPrec :: Int -> BackendSchemaField Sqlite -> ShowS # show :: BackendSchemaField Sqlite -> String # showList :: [BackendSchemaField Sqlite] -> ShowS #
Show (BackendSchemaField Redshift) #
Instance details Defined in Napkin.Run.Redshift Methods showsPrec :: Int -> BackendSchemaField Redshift -> ShowS # show :: BackendSchemaField Redshift -> String # showList :: [BackendSchemaField Redshift] -> ShowS #
Show (BackendSchemaField Postgres) #
Instance details Defined in Napkin.Run.Postgres Methods showsPrec :: Int -> BackendSchemaField Postgres -> ShowS # show :: BackendSchemaField Postgres -> String # showList :: [BackendSchemaField Postgres] -> ShowS #
Show (BackendSchemaField BigQuery) #
Instance details Defined in Napkin.Run.BigQuery Methods showsPrec :: Int -> BackendSchemaField BigQuery -> ShowS # show :: BackendSchemaField BigQuery -> String # showList :: [BackendSchemaField BigQuery] -> ShowS #
FromRow (BackendSchemaField Sqlite) #
Instance details Defined in Napkin.Run.Sqlite Methods fromRow :: RowParser (BackendSchemaField Sqlite) #
data BackendSchemaField Sqlite #
Instance details Defined in Napkin.Run.Sqlite data BackendSchemaField Sqlite = SqliteSchemaField { scdCid :: Int scdName :: Text scdType :: Text scdNullable :: Int scdDefaultValue :: Maybe Int scdPrimaryKey :: Int }
data BackendSchemaField Redshift #
Instance details Defined in Napkin.Run.Redshift data BackendSchemaField Redshift = RedshiftSchemaField PGSchemaField
data BackendSchemaField Postgres #
Instance details Defined in Napkin.Run.Postgres data BackendSchemaField Postgres = PostgresSchemaField PGSchemaField
data BackendSchemaField BigQuery #
Instance details Defined in Napkin.Run.BigQuery data BackendSchemaField BigQuery = BigQuerySchemaField TableFieldSchema

mkBigQueryEnv :: (MonadCatch m, Katip m) => Maybe FilePath -> DbBackendOptions BigQuery -> BQProjectId -> Maybe BQDataSetId -> m (BackendConn BigQuery) #

Creates a google BigQuery environment. Takes the Maybe provided credential file. If none, then try to use the gCloud SDK credentials.

mkBigQueryEnv' #

Arguments

:: (MonadCatch m, MonadIO m)
=> Natural	Number of concurrent requests
-> IO GoogleEnv	How do we set up each entry in the GoogleEnv pool?
-> BQProjectId
-> Maybe BQDataSetId
-> Labels
-> m (BackendConn BigQuery)

Makes a BigQuery env, but with control over configuring how the Google environment is set up. You should usually call mkGoogleEnv and then fmap some customization over it.

mkBigQueryEnvWithCredentials :: (MonadCatch m, Katip m) => Maybe ByteString -> Credentials BigQueryScopes -> DbBackendOptions BigQuery -> BQProjectId -> Maybe BQDataSetId -> m (BackendConn BigQuery) #

mkBigQueryEnvWithJsonCredentials :: (MonadCatch m, Katip m) => Maybe ByteString -> CredentialsJson -> DbBackendOptions BigQuery -> BQProjectId -> Maybe BQDataSetId -> m (BackendConn BigQuery) #

mkBigQueryEnvWithCredentialsFile :: (MonadCatch m, Katip m) => FilePath -> DbBackendOptions BigQuery -> BQProjectId -> Maybe BQDataSetId -> m (BackendConn BigQuery) #

Orphan instances

Backend BigQuery #
Instance details Associated Types data BackendConn BigQuery # Methods backendQuery :: (Katip m, MonadQueryStats m, RenderSql q BigQuery) => BackendConn BigQuery -> q -> m [Map Text Value] # backendExecute :: (Katip m, MonadQueryStats m, RenderSql q BigQuery) => BackendConn BigQuery -> q -> m () #
RunBackendConn BigQuery #
Instance details Methods runBackendConn :: LogEnv -> DbBackendOptions BigQuery -> ConnectionString -> Maybe AppName -> Maybe CredentialsPath -> SpecFile -> Maybe AuthPort -> (Pipeline -> BackendConn BigQuery -> IO a) -> IO a #
Command UpdateQuery () BigQuery #
Instance details Methods execCommand :: (Katip m, MonadQueryStats m) => BackendConn BigQuery -> UpdateQuery -> m () #
Command Grant () BigQuery #
Instance details Methods execCommand :: (Katip m, MonadQueryStats m) => BackendConn BigQuery -> Grant -> m () #
Command CheckTableExists Bool BigQuery #
Instance details Methods execCommand :: (Katip m, MonadQueryStats m) => BackendConn BigQuery -> CheckTableExists -> m Bool #
Command DeleteFrom () BigQuery #
Instance details Methods execCommand :: (Katip m, MonadQueryStats m) => BackendConn BigQuery -> DeleteFrom -> m () #
Command InsertIntoQuery () BigQuery #
Instance details Methods execCommand :: (Katip m, MonadQueryStats m) => BackendConn BigQuery -> InsertIntoQuery -> m () #
Command DropTable () BigQuery #
Instance details Methods execCommand :: (Katip m, MonadQueryStats m) => BackendConn BigQuery -> DropTable -> m () #
Command DropView () BigQuery #
Instance details Methods execCommand :: (Katip m, MonadQueryStats m) => BackendConn BigQuery -> DropView -> m () #
Command CopyTable () BigQuery #
Instance details Methods execCommand :: (Katip m, MonadQueryStats m) => BackendConn BigQuery -> CopyTable -> m () #
Command RenameTable () BigQuery #	BQ implements rename via copy-then-drop
Instance details Methods execCommand :: (Katip m, MonadQueryStats m) => BackendConn BigQuery -> RenameTable -> m () #
Command GetRelationSchema [BackendSchemaField BigQuery] BigQuery #
Instance details Methods execCommand :: (Katip m, MonadQueryStats m) => BackendConn BigQuery -> GetRelationSchema -> m [BackendSchemaField BigQuery] #
HasBackendSchemaField BigQuery #
Instance details Associated Types data BackendSchemaField BigQuery # Methods fieldName :: BackendSchemaField BigQuery -> Text # fieldType :: BackendSchemaField BigQuery -> Type #
Command (CreateMaterializedViewAs MaterializedViewMeta) () BigQuery #
Instance details Methods execCommand :: (Katip m, MonadQueryStats m) => BackendConn BigQuery -> CreateMaterializedViewAs MaterializedViewMeta -> m () #
Command (CreateViewAs ()) () BigQuery #
Instance details Methods execCommand :: (Katip m, MonadQueryStats m) => BackendConn BigQuery -> CreateViewAs () -> m () #
Command (CreateTableAs ()) () BigQuery #
Instance details Methods execCommand :: (Katip m, MonadQueryStats m) => BackendConn BigQuery -> CreateTableAs () -> m () #
Command (CreateTableAs TableMeta) () BigQuery #
Instance details Methods execCommand :: (Katip m, MonadQueryStats m) => BackendConn BigQuery -> CreateTableAs TableMeta -> m () #
Eq (BackendSchemaField BigQuery) #
Instance details Methods (==) :: BackendSchemaField BigQuery -> BackendSchemaField BigQuery -> Bool # (/=) :: BackendSchemaField BigQuery -> BackendSchemaField BigQuery -> Bool #
Show (BackendSchemaField BigQuery) #
Instance details Methods showsPrec :: Int -> BackendSchemaField BigQuery -> ShowS # show :: BackendSchemaField BigQuery -> String # showList :: [BackendSchemaField BigQuery] -> ShowS #