Inheritance diagram for lsst.pipe.tasks.ingestPgsql.PgsqlRegistryContext:

Public Member Functions
def	__init__ (self, registryName, createTableFunc, forceCreateTables)

def	__exit__ (self, excType, excValue, traceback)

def	__enter__ (self)

Public Attributes
	registryName

	conn

Detailed Description

Context manager to provide a pgsql registry

Definition at line 14 of file ingestPgsql.py.

Constructor & Destructor Documentation

◆ init()

def lsst.pipe.tasks.ingestPgsql.PgsqlRegistryContext.__init__	(	self,
		registryName,
		createTableFunc,
		forceCreateTables
	)

Construct a context manager

@param registryName: Name of registry file
@param createTableFunc: Function to create tables
@param forceCreateTables: Force the (re-)creation of tables?

Definition at line 17 of file ingestPgsql.py.

     def __init__(self, registryName, createTableFunc, forceCreateTables):
         """Construct a context manager
  
         @param registryName: Name of registry file
         @param createTableFunc: Function to create tables
         @param forceCreateTables: Force the (re-)creation of tables?
         """
         self.registryName = registryName
         data = PgsqlRegistry.readYaml(registryName)
         self.conn = pgsql.connect(host=data["host"], port=data["port"], user=data["user"],
                                   password=data["password"], database=data["database"])
         cur = self.conn.cursor()
  
         # Check for existence of tables
         cur.execute("SELECT relname FROM pg_class WHERE relkind='r' AND relname='raw'")
         rows = cur.fetchall()
  
         if forceCreateTables or len(rows) == 0:
             # Delete all tables and start over.
             # Not simply doing "DROP SCHEMA" and "CREATE SCHEMA" because of permissions.
             cur.execute("SELECT tablename FROM pg_tables WHERE schemaname = 'public'")
             tables = cur.fetchall()
             for tt in tables:
                 cur.execute("DROP TABLE %s CASCADE" % tt)
             createTableFunc(self.conn)
  

Member Function Documentation

◆ enter()

def lsst.pipe.tasks.ingest.RegistryContext.__enter__ ( self )

inherited

Provide the 'as' value

Definition at line 261 of file ingest.py.

     def __enter__(self):
         """Provide the 'as' value"""
         return self.conn
  

◆ exit()

def lsst.pipe.tasks.ingestPgsql.PgsqlRegistryContext.__exit__	(	self,
		excType,
		excValue,
		traceback
	)

Reimplemented from lsst.pipe.tasks.ingest.RegistryContext.

Definition at line 43 of file ingestPgsql.py.

     def __exit__(self, excType, excValue, traceback):
         self.conn.commit()
         self.conn.close()
         return False  # Don't suppress any exceptions
  
  

Member Data Documentation

◆ conn

lsst.pipe.tasks.ingestPgsql.PgsqlRegistryContext.conn

Definition at line 26 of file ingestPgsql.py.

◆ registryName

lsst.pipe.tasks.ingestPgsql.PgsqlRegistryContext.registryName

Definition at line 24 of file ingestPgsql.py.

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

/j/snowflake/release/lsstsw/stack/lsst-scipipe-0.7.0/Linux64/pipe_tasks/21.0.0-147-g0e635eb1+1acddb5be5/python/lsst/pipe/tasks/ingestPgsql.py

Public Member Functions

Public Attributes