@contextmanager
def _conn(commit=False):
 defaults = {'host': 'localhost', 'user': 'salt', 'password': 'salt', 'dbname': 'salt', 'port': 5432}
 conn_kwargs = {}
 for (key, value) in defaults.items():
  conn_kwargs[key] = __opts__.get('queue.{0}.{1}'.format(__virtualname__, key), value)
 try:
  conn = psycopg2.connect(**conn_kwargs)
 except psycopg2.OperationalError as exc:
  raise SaltMasterError('pgjsonb returner could not connect to database: {exc}'.format(exc=exc))
 cursor = conn.cursor()
 try:
  (yield cursor)
 except psycopg2.DatabaseError as err:
  error = err.args
  sys.stderr.write(str(error))
  cursor.execute('ROLLBACK')
  raise err
 else:
  if commit:
   cursor.execute('COMMIT')
  else:
   cursor.execute('ROLLBACK')
 finally:
  conn.close()

@ contextmanager def _conn ( commit = False ) : defaults = { 'host' : 'localhost' , 'user' : 'salt' , 'password' : 'salt' , 'dbname' : 'salt' , 'port' : 5432 } conn_kwargs = { } for ( key , value ) in defaults . items ( ) : conn_kwargs [ key ] = __opts__ . get ( 'queue.{0}.{1}' . format ( __virtualname__ , key ) , value ) try : conn = psycopg2 . connect ( ** conn_kwargs ) except psycopg2 . OperationalError as exc : raise SaltMasterError ( 'pgjsonb returner could not connect to database: {exc}' . format ( exc = exc ) ) cursor = conn . cursor ( ) try : ( yield cursor ) except psycopg2 . DatabaseError as err : error = err . args sys . stderr . write ( str ( error ) ) cursor . execute ( 'ROLLBACK' ) raise err else : if commit : cursor . execute ( 'COMMIT' ) else : cursor . execute ( 'ROLLBACK' ) finally : conn . close ( )
return an postgres cursor .