Inheritance diagram for lsst.dax.apdb.sql.apdbSql.ApdbSql:

Public Member Functions
	__init__ (self, ApdbSqlConfig config)

VersionTuple	apdbImplementationVersion (cls)

ApdbSqlConfig	init_database (cls, str db_url, *, str\|None schema_file=None, str\|None ss_schema_file=None, int\|None read_sources_months=None, int\|None read_forced_sources_months=None, bool enable_replica=False, int\|None connection_timeout=None, str\|None dia_object_index=None, int\|None htm_level=None, str\|None htm_index_column=None, tuple[str, str]\|None ra_dec_columns=None, str\|None prefix=None, str\|None namespace=None, bool drop=False)

ApdbSqlReplica	get_replica (self)

dict[str, int]	tableRowCount (self)

ApdbSqlConfig	getConfig (self)

Table\|None	tableDef (self, ApdbTables table)

pandas.DataFrame	getDiaObjects (self, Region region)

pandas.DataFrame\|None	getDiaSources (self, Region region, Iterable[int]\|None object_ids, astropy.time.Time visit_time, astropy.time.Time\|None start_time=None)

pandas.DataFrame\|None	getDiaForcedSources (self, Region region, Iterable[int]\|None object_ids, astropy.time.Time visit_time, astropy.time.Time\|None start_time=None)

bool	containsVisitDetector (self, int visit, int detector, Region region, astropy.time.Time visit_time)

None	store (self, astropy.time.Time visit_time, pandas.DataFrame objects, pandas.DataFrame\|None sources=None, pandas.DataFrame\|None forced_sources=None)

None	reassignDiaSources (self, Mapping[int, int] idMap)

None	dailyJob (self)

int	countUnassociatedObjects (self)

ApdbMetadata	metadata (self)

ApdbSqlAdmin	admin (self)

Public Member Functions inherited from lsst.dax.apdb.apdb.Apdb
Apdb	from_config (cls, ApdbConfig config)

Apdb	from_uri (cls, ResourcePathExpression uri)

Public Attributes
	config = freezer.update(config, config_json)

	pixelator = HtmPixelization(self.config.pixelization.htm_level)

Static Public Attributes
str	metadataSchemaVersionKey = "version:schema"

str	metadataCodeVersionKey = "version:ApdbSql"

str	metadataReplicaVersionKey = "version:ApdbSqlReplica"

str	metadataConfigKey = "config:apdb-sql.json"

Protected Member Functions
Timer	_timer (self, str name, *, Mapping[str, str\|int]\|None tags=None)

sqlalchemy.engine.Engine	_makeEngine (cls, ApdbSqlConfig config, *, bool create)

sqlalchemy.engine.URL\|str	_connection_url (cls, str config_url, *, bool create)

str	_update_sqlite_url (cls, str url_string)

VersionTuple	_versionCheck (self, ApdbMetadataSql metadata)

None	_makeSchema (cls, ApdbConfig config, bool drop=False)

pandas.DataFrame	_getDiaSourcesInRegion (self, Region region, float start_time_mjdTai)

pandas.DataFrame	_getDiaSourcesByIDs (self, list[int] object_ids, float start_time_mjdTai)

pandas.DataFrame	_getSourcesByIDs (self, ApdbTables table_enum, list[int] object_ids, float midpointMjdTai_start)

None	_storeReplicaChunk (self, ReplicaChunk replica_chunk, sqlalchemy.engine.Connection connection)

None	_storeDiaObjects (self, pandas.DataFrame objs, astropy.time.Time visit_time, ReplicaChunk\|None replica_chunk, sqlalchemy.engine.Connection connection)

None	_storeDiaSources (self, pandas.DataFrame sources, ReplicaChunk\|None replica_chunk, sqlalchemy.engine.Connection connection)

None	_storeDiaForcedSources (self, pandas.DataFrame sources, ReplicaChunk\|None replica_chunk, sqlalchemy.engine.Connection connection)

None	_storeUpdateRecords (self, Iterable[ApdbUpdateRecord] records, ReplicaChunk chunk, *, bool store_chunk=False, sqlalchemy.engine.Connection\|None connection=None)

list[tuple[int, int]]	_htm_indices (self, Region region)

sql.ColumnElement	_filterRegion (self, sqlalchemy.schema.Table table, Region region)

pandas.DataFrame	_add_spatial_index (self, pandas.DataFrame df)

pandas.DataFrame	_fix_input_timestamps (self, pandas.DataFrame df)

pandas.DataFrame	_fix_result_timestamps (self, pandas.DataFrame df)

Protected Attributes
sqlalchemy.engine.Engine	_engine = self._makeEngine(config, create=False)

	_metadata = ApdbMetadataSql(self._engine, meta_table)

	_schema

VersionTuple	_db_schema_version = self._versionCheck(self._metadata)

Static Protected Attributes
tuple	_frozen_parameters

Detailed Description

Implementation of APDB interface based on SQL database.

The implementation is configured via standard ``pex_config`` mechanism
using `ApdbSqlConfig` configuration class. For an example of different
configurations check ``config/`` folder.

Parameters
----------
config : `ApdbSqlConfig`
    Configuration object.

Member Function Documentation

◆ _add_spatial_index()

pandas.DataFrame lsst.dax.apdb.sql.apdbSql.ApdbSql._add_spatial_index	(		self,
		pandas.DataFrame	df )

protected

Calculate spatial index for each record and add it to a DataFrame.

Parameters
----------
df : `pandas.DataFrame`
    DataFrame which has to contain ra/dec columns, names of these
    columns are defined by configuration ``ra_dec_columns`` field.

Returns
-------
df : `pandas.DataFrame`
    DataFrame with ``pixelId`` column which contains pixel index
    for ra/dec coordinates.

Notes
-----
This overrides any existing column in a DataFrame with the same name
(pixelId). Original DataFrame is not changed, copy of a DataFrame is
returned.

◆ _connection_url()

sqlalchemy.engine.URL \| str lsst.dax.apdb.sql.apdbSql.ApdbSql._connection_url	(		cls,
		str	config_url,
		*	,
		bool	create )

protected

Generate a complete URL for database with proper credentials.

Parameters
----------
config_url : `str`
    Database URL as specified in configuration.
create : `bool`
    Whether to try to create new database file, only relevant for
    SQLite backend which always creates new files by default.

Returns
-------
connection_url : `sqlalchemy.engine.URL` or `str`
    Connection URL including credentials.

◆ _filterRegion()

sql.ColumnElement lsst.dax.apdb.sql.apdbSql.ApdbSql._filterRegion	(		self,
		sqlalchemy.schema.Table	table,
		Region	region )

protected

Make SQLAlchemy expression for selecting records in a region.

◆ _fix_input_timestamps()

pandas.DataFrame lsst.dax.apdb.sql.apdbSql.ApdbSql._fix_input_timestamps	(		self,
		pandas.DataFrame	df )

protected

Update timestamp columns in input DataFrame to be aware datetime
type in in UTC.

AP pipeline generates naive datetime instances, we want them to be
aware before they go to database. All naive timestamps are assumed to
be in UTC timezone (they should be TAI).

◆ _fix_result_timestamps()

pandas.DataFrame lsst.dax.apdb.sql.apdbSql.ApdbSql._fix_result_timestamps	(		self,
		pandas.DataFrame	df )

protected

Update timestamp columns to be naive datetime type in returned
DataFrame.

AP pipeline code expects DataFrames to contain naive datetime columns,
while Postgres queries return timezone-aware type. This method converts
those columns to naive datetime in UTC timezone.

◆ _getDiaSourcesByIDs()

pandas.DataFrame lsst.dax.apdb.sql.apdbSql.ApdbSql._getDiaSourcesByIDs	(		self,
		list[int]	object_ids,
		float	start_time_mjdTai )

protected

Return catalog of DiaSource instances given set of DiaObject IDs.

Parameters
----------
object_ids :
    Collection of DiaObject IDs
start_time_mjdTai : `float`
    Lower bound of time window for the query.

Returns
-------
catalog : `pandas.DataFrame`
    Catalog containing DiaSource records.

◆ _getDiaSourcesInRegion()

pandas.DataFrame lsst.dax.apdb.sql.apdbSql.ApdbSql._getDiaSourcesInRegion	(		self,
		Region	region,
		float	start_time_mjdTai )

protected

Return catalog of DiaSource instances from given region.

Parameters
----------
region : `lsst.sphgeom.Region`
    Region to search for DIASources.
start_time_mjdTai : `float`
    Lower bound of time window for the query.

Returns
-------
catalog : `pandas.DataFrame`
    Catalog containing DiaSource records.

◆ _getSourcesByIDs()

pandas.DataFrame lsst.dax.apdb.sql.apdbSql.ApdbSql._getSourcesByIDs	(		self,
		ApdbTables	table_enum,
		list[int]	object_ids,
		float	midpointMjdTai_start )

protected

Return catalog of DiaSource or DiaForcedSource instances given set
of DiaObject IDs.

Parameters
----------
table : `sqlalchemy.schema.Table`
    Database table.
object_ids :
    Collection of DiaObject IDs
midpointMjdTai_start : `float`
    Earliest midpointMjdTai to retrieve.

Returns
-------
catalog : `pandas.DataFrame`
    Catalog contaning DiaSource records. `None` is returned if
    ``read_sources_months`` configuration parameter is set to 0 or
    when ``object_ids`` is empty.

◆ _htm_indices()

list[tuple[int, int]] lsst.dax.apdb.sql.apdbSql.ApdbSql._htm_indices	(		self,
		Region	region )

protected

Generate a set of HTM indices covering specified region.

Parameters
----------
region: `sphgeom.Region`
    Region that needs to be indexed.

Returns
-------
Sequence of ranges, range is a tuple (minHtmID, maxHtmID).

◆ _makeEngine()

sqlalchemy.engine.Engine lsst.dax.apdb.sql.apdbSql.ApdbSql._makeEngine	(		cls,
		ApdbSqlConfig	config,
		*	,
		bool	create )

protected

Make SQLALchemy engine based on configured parameters.

Parameters
----------
config : `ApdbSqlConfig`
    Configuration object.
create : `bool`
    Whether to try to create new database file, only relevant for
    SQLite backend which always creates new files by default.

◆ _storeDiaForcedSources()

None lsst.dax.apdb.sql.apdbSql.ApdbSql._storeDiaForcedSources	(		self,
		pandas.DataFrame	sources,
		ReplicaChunk \| None	replica_chunk,
		sqlalchemy.engine.Connection	connection )

protected

Store a set of DiaForcedSources from current visit.

Parameters
----------
sources : `pandas.DataFrame`
    Catalog containing DiaForcedSource records

◆ _storeDiaObjects()

None lsst.dax.apdb.sql.apdbSql.ApdbSql._storeDiaObjects	(		self,
		pandas.DataFrame	objs,
		astropy.time.Time	visit_time,
		ReplicaChunk \| None	replica_chunk,
		sqlalchemy.engine.Connection	connection )

protected

Store catalog of DiaObjects from current visit.

Parameters
----------
objs : `pandas.DataFrame`
    Catalog with DiaObject records.
visit_time : `astropy.time.Time`
    Time of the visit.
replica_chunk : `ReplicaChunk`
    Insert identifier.

◆ _storeDiaSources()

None lsst.dax.apdb.sql.apdbSql.ApdbSql._storeDiaSources	(		self,
		pandas.DataFrame	sources,
		ReplicaChunk \| None	replica_chunk,
		sqlalchemy.engine.Connection	connection )

protected

Store catalog of DiaSources from current visit.

Parameters
----------
sources : `pandas.DataFrame`
    Catalog containing DiaSource records

◆ _storeUpdateRecords()

None lsst.dax.apdb.sql.apdbSql.ApdbSql._storeUpdateRecords	(		self,
		Iterable[ApdbUpdateRecord]	records,
		ReplicaChunk	chunk,
		*	,
		bool	store_chunk = False,
		sqlalchemy.engine.Connection \| None	connection = None )

protected

Store ApdbUpdateRecords in the replica table for those records.

Parameters
----------
records : `list` [`ApdbUpdateRecord`]
    Records to store.
chunk : `ReplicaChunk`
    Replica chunk for these records.
store_chunk : `bool`
    If True then also store replica chunk.
connection : `sqlalchemy.engine.Connection`
    SQLALchemy connection to use, if `None` the new connection will be
    made. `None` is useful for tests only, regular use will call this
    method in the same transaction that saves other types of records.

Raises
------
TypeError
    Raised if replication is not enabled for this instance.

◆ _timer()

Timer lsst.dax.apdb.sql.apdbSql.ApdbSql._timer	(		self,
		str	name,
		*	,
		Mapping[str, str \| int] \| None	tags = None )

protected

Create `Timer` instance given its name.

◆ _update_sqlite_url()

str lsst.dax.apdb.sql.apdbSql.ApdbSql._update_sqlite_url	(		cls,
		str	url_string )

protected

If URL refers to sqlite dialect, update it so that the backend does
not try to create database file if it does not exist already.

Parameters
----------
url_string : `str`
    Connection string.

Returns
-------
url_string : `str`
    Possibly updated connection string.

◆ _versionCheck()

VersionTuple lsst.dax.apdb.sql.apdbSql.ApdbSql._versionCheck	(		self,
		ApdbMetadataSql	metadata )

protected

Check schema version compatibility and return the database schema
version.

◆ admin()

ApdbSqlAdmin lsst.dax.apdb.sql.apdbSql.ApdbSql.admin ( self )

Object providing adminitrative interface for APDB (`ApdbAdmin`).

Reimplemented from lsst.dax.apdb.apdb.Apdb.

◆ apdbImplementationVersion()

VersionTuple lsst.dax.apdb.sql.apdbSql.ApdbSql.apdbImplementationVersion ( cls )

Return version number for current APDB implementation.

Returns
-------
version : `VersionTuple`
    Version of the code defined in implementation class.

◆ containsVisitDetector()

bool lsst.dax.apdb.sql.apdbSql.ApdbSql.containsVisitDetector	(		self,
		int	visit,
		int	detector,
		Region	region,
		astropy.time.Time	visit_time )

Test whether any sources for a given visit-detector are present in
the APDB.

Parameters
----------
visit, detector : `int`
    The ID of the visit-detector to search for.
region : `lsst.sphgeom.Region`
    Region corresponding to the visit/detector combination.
visit_time : `astropy.time.Time`
    Visit time (as opposed to visit processing time). This can be any
    timestamp in the visit timespan, e.g. its begin or end time.

Returns
-------
present : `bool`
    `True` if at least one DiaSource or DiaForcedSource record
    may exist for the specified observation, `False` otherwise.

Reimplemented from lsst.dax.apdb.apdb.Apdb.

◆ countUnassociatedObjects()

int lsst.dax.apdb.sql.apdbSql.ApdbSql.countUnassociatedObjects ( self )

Return the number of DiaObjects that have only one DiaSource
associated with them.

Used as part of ap_verify metrics.

Returns
-------
count : `int`
    Number of DiaObjects with exactly one associated DiaSource.

Notes
-----
This method can be very inefficient or slow in some implementations.

Reimplemented from lsst.dax.apdb.apdb.Apdb.

◆ dailyJob()

None lsst.dax.apdb.sql.apdbSql.ApdbSql.dailyJob ( self )

Implement daily activities like cleanup/vacuum.

What should be done during daily activities is determined by
specific implementation.

Reimplemented from lsst.dax.apdb.apdb.Apdb.

◆ get_replica()

ApdbSqlReplica lsst.dax.apdb.sql.apdbSql.ApdbSql.get_replica ( self )

Return `ApdbReplica` instance for this database.

◆ getConfig()

ApdbSqlConfig lsst.dax.apdb.sql.apdbSql.ApdbSql.getConfig ( self )

Return APDB configuration for this instance, including any updates
that may be read from database.

Returns
-------
config : `ApdbConfig`
    APDB configuration.

Reimplemented from lsst.dax.apdb.apdb.Apdb.

◆ getDiaForcedSources()

pandas.DataFrame \| None lsst.dax.apdb.sql.apdbSql.ApdbSql.getDiaForcedSources	(		self,
		Region	region,
		Iterable[int] \| None	object_ids,
		astropy.time.Time	visit_time,
		astropy.time.Time \| None	start_time = None )

Return catalog of DiaForcedSource instances from a given region.

Parameters
----------
region : `lsst.sphgeom.Region`
    Region to search for DIASources.
object_ids : iterable [ `int` ], optional
    List of DiaObject IDs to further constrain the set of returned
    sources. If list is empty then empty catalog is returned with a
    correct schema. If `None` then returned sources are not
    constrained.
visit_time : `astropy.time.Time`
    Time of the current visit. If APDB contains records later than this
    time they may also be returned.
start_time : `astropy.time.Time`, optional
    Lower bound of time window for the query. If not specified then
    it is calculated using ``visit_time`` and
    ``read_forced_sources_months`` configuration parameter.

Returns
-------
catalog : `pandas.DataFrame`, or `None`
    Catalog containing DiaForcedSource records. `None` is returned if
    ``start_time`` is not specified and ``read_forced_sources_months``
    configuration parameter is set to 0.

Raises
------
NotImplementedError
    May be raised by some implementations if ``object_ids`` is `None`.

Notes
-----
This method returns DiaForcedSource catalog for a region with
additional filtering based on DiaObject IDs. Only a subset of DiaSource
history is returned limited by ``read_forced_sources_months`` config
parameter, w.r.t. ``visit_time``. If ``object_ids`` is empty then an
empty catalog is always returned with the correct schema
(columns/types). If ``object_ids`` is `None` then no filtering is
performed and some of the returned records may be outside the specified
region.

Reimplemented from lsst.dax.apdb.apdb.Apdb.

◆ getDiaObjects()

pandas.DataFrame lsst.dax.apdb.sql.apdbSql.ApdbSql.getDiaObjects	(		self,
		Region	region )

Return catalog of DiaObject instances from a given region.

This method returns only the last version of each DiaObject,
and may return only the subset of the DiaObject columns needed
for AP association. Some
records in a returned catalog may be outside the specified region, it
is up to a client to ignore those records or cleanup the catalog before
futher use.

Parameters
----------
region : `lsst.sphgeom.Region`
    Region to search for DIAObjects.

Returns
-------
catalog : `pandas.DataFrame`
    Catalog containing DiaObject records for a region that may be a
    superset of the specified region.

Reimplemented from lsst.dax.apdb.apdb.Apdb.

◆ getDiaSources()

pandas.DataFrame \| None lsst.dax.apdb.sql.apdbSql.ApdbSql.getDiaSources	(		self,
		Region	region,
		Iterable[int] \| None	object_ids,
		astropy.time.Time	visit_time,
		astropy.time.Time \| None	start_time = None )

Return catalog of DiaSource instances from a given region.

Parameters
----------
region : `lsst.sphgeom.Region`
    Region to search for DIASources.
object_ids : iterable [ `int` ], optional
    List of DiaObject IDs to further constrain the set of returned
    sources. If `None` then returned sources are not constrained. If
    list is empty then empty catalog is returned with a correct
    schema.
visit_time : `astropy.time.Time`
    Time of the current visit. If APDB contains records later than this
    time they may also be returned.
start_time : `astropy.time.Time`, optional
    Lower bound of time window for the query. If not specified then
    it is calculated using ``visit_time`` and
    ``read_forced_sources_months`` configuration parameter.

Returns
-------
catalog : `pandas.DataFrame`, or `None`
    Catalog containing DiaSource records. `None` is returned if
    ``start_time`` is not specified and ``read_sources_months``
    configuration parameter is set to 0.

Notes
-----
This method returns DiaSource catalog for a region with additional
filtering based on DiaObject IDs. Only a subset of DiaSource history
is returned limited by ``read_sources_months`` config parameter, w.r.t.
``visit_time``. If ``object_ids`` is empty then an empty catalog is
always returned with the correct schema (columns/types). If
``object_ids`` is `None` then no filtering is performed and some of the
returned records may be outside the specified region.

Reimplemented from lsst.dax.apdb.apdb.Apdb.

◆ init_database()

ApdbSqlConfig lsst.dax.apdb.sql.apdbSql.ApdbSql.init_database	(		cls,
		str	db_url,
		*	,
		str \| None	schema_file = None,
		str \| None	ss_schema_file = None,
		int \| None	read_sources_months = None,
		int \| None	read_forced_sources_months = None,
		bool	enable_replica = False,
		int \| None	connection_timeout = None,
		str \| None	dia_object_index = None,
		int \| None	htm_level = None,
		str \| None	htm_index_column = None,
		tuple[str, str] \| None	ra_dec_columns = None,
		str \| None	prefix = None,
		str \| None	namespace = None,
		bool	drop = False )

Initialize new APDB instance and make configuration object for it.

Parameters
----------
db_url : `str`
    SQLAlchemy database URL.
schema_file : `str`, optional
    Location of (YAML) configuration file with APDB schema. If not
    specified then default location will be used.
ss_schema_file : `str`, optional
    Location of (YAML) configuration file with SSO schema. If not
    specified then default location will be used.
read_sources_months : `int`, optional
    Number of months of history to read from DiaSource.
read_forced_sources_months : `int`, optional
    Number of months of history to read from DiaForcedSource.
enable_replica : `bool`, optional
    If True, make additional tables used for replication to PPDB.
connection_timeout : `int`, optional
    Database connection timeout in seconds.
dia_object_index : `str`, optional
    Indexing mode for DiaObject table.
htm_level : `int`, optional
    HTM indexing level.
htm_index_column : `str`, optional
    Name of a HTM index column for DiaObject and DiaSource tables.
ra_dec_columns : `tuple` [`str`, `str`], optional
    Names of ra/dec columns in DiaObject table.
prefix : `str`, optional
    Optional prefix for all table names.
namespace : `str`, optional
    Name of the database schema for all APDB tables. If not specified
    then default schema is used.
drop : `bool`, optional
    If `True` then drop existing tables before re-creating the schema.

Returns
-------
config : `ApdbSqlConfig`
    Resulting configuration object for a created APDB instance.

◆ metadata()

ApdbMetadata lsst.dax.apdb.sql.apdbSql.ApdbSql.metadata ( self )

Object controlling access to APDB metadata (`ApdbMetadata`).

Reimplemented from lsst.dax.apdb.apdb.Apdb.

◆ reassignDiaSources()

None lsst.dax.apdb.sql.apdbSql.ApdbSql.reassignDiaSources	(		self,
		Mapping[int, int]	idMap )

Associate DiaSources with SSObjects, dis-associating them
from DiaObjects.

Parameters
----------
idMap : `Mapping`
    Maps DiaSource IDs to their new SSObject IDs.

Raises
------
ValueError
    Raised if DiaSource ID does not exist in the database.

Reimplemented from lsst.dax.apdb.apdb.Apdb.

◆ store()

None lsst.dax.apdb.sql.apdbSql.ApdbSql.store	(		self,
		astropy.time.Time	visit_time,
		pandas.DataFrame	objects,
		pandas.DataFrame \| None	sources = None,
		pandas.DataFrame \| None	forced_sources = None )

Store all three types of catalogs in the database.

Parameters
----------
visit_time : `astropy.time.Time`
    Time of the visit.
objects : `pandas.DataFrame`
    Catalog with DiaObject records.
sources : `pandas.DataFrame`, optional
    Catalog with DiaSource records.
forced_sources : `pandas.DataFrame`, optional
    Catalog with DiaForcedSource records.

Notes
-----
This methods takes DataFrame catalogs, their schema must be
compatible with the schema of APDB table:

  - column names must correspond to database table columns
  - types and units of the columns must match database definitions,
    no unit conversion is performed presently
  - columns that have default values in database schema can be
    omitted from catalog
  - this method knows how to fill interval-related columns of DiaObject
    (validityStart, validityEnd) they do not need to appear in a
    catalog
  - source catalogs have ``diaObjectId`` column associating sources
    with objects

This operation need not be atomic, but DiaSources and DiaForcedSources
will not be stored until all DiaObjects are stored.

Reimplemented from lsst.dax.apdb.apdb.Apdb.

◆ tableDef()

Table \| None lsst.dax.apdb.sql.apdbSql.ApdbSql.tableDef	(		self,
		ApdbTables	table )

Return table schema definition for a given table.

Parameters
----------
table : `ApdbTables`
    One of the known APDB tables.

Returns
-------
tableSchema : `.schema_model.Table` or `None`
    Table schema description, `None` is returned if table is not
    defined by this implementation.

Reimplemented from lsst.dax.apdb.apdb.Apdb.

◆ tableRowCount()

dict[str, int] lsst.dax.apdb.sql.apdbSql.ApdbSql.tableRowCount ( self )

Return dictionary with the table names and row counts.

Used by ``ap_proto`` to keep track of the size of the database tables.
Depending on database technology this could be expensive operation.

Returns
-------
row_counts : `dict`
    Dict where key is a table name and value is a row count.

Member Data Documentation

◆ _frozen_parameters

tuple lsst.dax.apdb.sql.apdbSql.ApdbSql._frozen_parameters

staticprotected

Initial value:

=  (
        "enable_replica",
        "dia_object_index",
        "pixelization.htm_level",
        "pixelization.htm_index_column",
        "ra_dec_columns",
    )

◆ _schema

lsst.dax.apdb.sql.apdbSql.ApdbSql._schema

protected

Initial value:

=  ApdbSqlSchema(
            engine=self._engine,
            dia_object_index=self.config.dia_object_index,
            schema_file=self.config.schema_file,
            ss_schema_file=self.config.ss_schema_file,
            prefix=self.config.prefix,
            namespace=self.config.namespace,
            htm_index_column=self.config.pixelization.htm_index_column,
            enable_replica=self.config.enable_replica,
        )

The documentation for this class was generated from the following file:

python/lsst/dax/apdb/sql/apdbSql.py

Public Member Functions

Public Attributes

Static Public Attributes

Protected Member Functions

Protected Attributes

Static Protected Attributes

Detailed Description

Member Function Documentation

◆ _add_spatial_index()

◆ _connection_url()

◆ _filterRegion()

◆ _fix_input_timestamps()

◆ _fix_result_timestamps()

◆ _getDiaSourcesByIDs()

◆ _getDiaSourcesInRegion()

◆ _getSourcesByIDs()

◆ _htm_indices()

◆ _makeEngine()

◆ _storeDiaForcedSources()

◆ _storeDiaObjects()

◆ _storeDiaSources()

◆ _storeUpdateRecords()

◆ _timer()

◆ _update_sqlite_url()

◆ _versionCheck()

◆ admin()

◆ apdbImplementationVersion()

◆ containsVisitDetector()

◆ countUnassociatedObjects()

◆ dailyJob()

◆ get_replica()

◆ getConfig()

◆ getDiaForcedSources()

◆ getDiaObjects()

◆ getDiaSources()

◆ init_database()

◆ metadata()

◆ reassignDiaSources()

◆ store()

◆ tableDef()

◆ tableRowCount()

Member Data Documentation

◆ _frozen_parameters

◆ _schema