ó
º¿cc@sËdZd
dl
Z
d
dlZd
dlZd
dlZd
dlZd
dlZd
dlmZ	
d
dlm
Z
d
dlm
Z

d
dlmZ
d
dlmZ
d
dlmZ
d
d	lmZ
d
d
lmZ
d
dlmZ
d
dlmZ
d
dlZd
d
lmZ
d
dlZd
dlmZ
d
dlmZ
d
dl m!Z!
d
dl"m#Z#
d
dlm$Z$
d
dlm%Z%
d
dlm&Z&
d
dl'm(Z(
d
dl'm)Z)
d
dl'm*Z*
d
dl'm+Z+
d
dl'm,Z,
d
dl'm-Z-
d
dl.m/Z/
d
dlm0Z0
d
dl1m2Z2
d
dl1m3Z3
d
dl1m4Z4
d
d l1m5Z5
d
d!l6m7Z7
d
d"l6m8Z8
d
d#l6m9Z9
d
d$l6m:Z:
d
dl;Z<d
dl=Z<d
d%l>m?Z?
d
dl<m
Z

d
d&l@mAZA
d
d'l<mBZB
ejCd(ƒ
ZDe<jEjFZFejGeHƒ
ZIe
jJƒZKe
jJƒZLd)„ZMdd*„
ZOd+„ZPddeQd,„ZRdd-„
ZSd.„ZTd/„ZUd0„ZVd1„ZWeWeTdd2„
ƒ
ƒ
ZXdd3„
ZYdd4„
ZZd5„Z[d6„Z\d7„Z]d8„ZTe\d9„ƒ
Z^e]d:„ƒ
Z_e]d;„ƒ
Z`eTd<„ƒ
Zae]dd=„
ƒ
Zbe]d>„ƒ
Zce]d?„ƒ
Zde]eQd@„
ƒ
Zee]eQdA„
ƒ
Zfe]dB„ƒ
Zge]dC„ƒ
ZheTdD„ƒ
Zie\dE„ƒ
Zje	jkdFdGdHelƒe\dI„ƒ
ƒ
ZmdS(Js%Implementation of SQLAlchemy backend.iÿÿÿÿN(
tapi(
t	exception(
tenginefacade(
tupdate_match(
tutils(
tlog(
texcutils(
timportutils(
t	timeutils(
t	uuidutils(
trange(
tand_(
tBoolean(
tNoSuchTableError(
tcompiles(
tInteger(
tMetaData(
tor_(
taliased(
tcontains_eager(
t
joinedload(
tjoinedload_all(
tnoload(
tundefer(
tTable(
tsql(
tasc(
tcast(
tdesc(
t
UpdateBase(
tfalse(
tfunc(
tnull(
ttrue(
tmodels(
t
_(
t
safe_utilssosprofiler.sqlalchemycCstj
tS(
s"The backend is this module itself.(tsystmodulest__name__(((s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pytget_backendEscCs5tt
|jƒƒ
ƒ
}|
dk	r1|
|d
<n|S(Nt
connection(tdicttlisttitemstNone(t
conf_groupR)tkw((s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyt_get_db_confIs




c

CsYtj
t|jƒ

tj
t|jƒ

trUtjd
„ƒ

tjd„ƒ

ndS(Nc

Sstj
t|d
ƒS(Ntdb(tprofiler_sqlalchemytadd_tracingtsa(
teng((s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyt<lambda>Wsc

Sstj
t|d
ƒS(NR1(R2R3R4(
R5((s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyR6Ys(tmain_context_managert	configureR0tdatabasetapi_context_managertapi_databaseR2tappend_on_engine_create(
tconf((s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyR8Os






cCs
|dkr|j
}ni}d
|kr7t|d<n>d|krPt|d<n%d|kr_nttdƒ
|ƒ
‚
tj|
|j||}t	j
j|ƒ
rÿ|rÿ|dkrç|jt
|
j|jk|
jtƒkƒƒ
}qÿ|jd|jƒ
}n|S(	s9Query helper that accounts for context's `read_deleted` field.

    :param context:     ContegoserverContext of the query.
    :param model:       Model to query. Must be a subclass of ModelBase.
    :param args:        Arguments to query. If None - model is used.
    :param read_deleted: If not None, overrides context's read_deleted field.
                        Permitted values are 'no', which does not return
                        deleted values; 'only', which only returns deleted
                        values; and 'yes', which does not filter deleted
                        values.
    :param project_only: If set and context is user-type, then restrict
                        query to match the context's project_id. If set to
                        'allow_none', restriction includes project_id = None.
    tnotdeletedtonlytyess$Unrecognized read_deleted value '%s't
allow_nonet
project_idN(R-tread_deletedtFalsetTruet
ValueErrorR#tsqlalchemyutilstmodel_querytsessiontdmapitcontexttis_user_contexttfilterRRCR t	filter_by(RLtmodeltargsRDtproject_onlytquery_kwargstquery((s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyRI\s(















cCsìt|t
jd
tƒ
jtdƒ
ƒ
jtdƒ
ƒ
}|
dkrQddg}
nxY|
D]Q}|dkrpqXnd|kr”|jt|ƒ
ƒ
}qX|jt|ƒ
ƒ
}qXWx8ddgD]*}||
krº|jt	|ƒ
ƒ
}qºqºW|S(	NRRssecurity_groups.rulest
info_cachetmetadatatsystem_metadatatsecurity_groupssextra.(RURX(
RIR"tInstanceRFtoptionsRRR-RR(RLtcolumns_to_joinRTtcolumntcol((s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyt_build_instance_gets











c
s"tj
ˆƒ
‡f
d
†ƒ
}
|
S(sÅDecorator to use a reader.allow_async db context manager.

    The db context manager will be picked from the RequestContext.

    Wrapped function must have a RequestContext in the arguments.
    c
s<t|ƒ
}|j
jj|ƒ

ˆ||
|Ž
SWdQXdS(
N(tget_context_managertreadertallow_asynctusing(RLRQtkwargstctxt_mgr(
t
f(s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pytwrapped©s

(t	functoolstwraps(ReRf((
Res;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyt'pick_context_manager_reader_allow_async¢sc

Cst|ƒ
pt
S(
swGet a database context manager object.

    :param context: The request context that can contain a context manager
    (t_context_manager_from_contextR7(
RL((s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyR_°sc

Cs,|r(y|jSWq(t
k
r$


q(XndS(
N(t
db_connectiontAttributeError(
RL((s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyRj¶s






c
s"tj
ˆƒ
‡f
d
†ƒ
}
|
S(sE
Decorator to require *any* user or admin context.

    This does no authorization for user or project access matching, see
    :py:func:`Contegoserver.context.authorize_project_context` and
    :py:func:`Contegoserver.context.authorize_user_context`.

    The first argument to the wrapped function must be the context.

    cs!tj
j|d
ƒ

ˆ||
ŽS(Ni(RKRLtrequire_context(RQRc(
Re(s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pytwrapperÈs
(RgRh(ReRn((
Res;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyRm½scCst||
d
|ƒ
S(NR[(
t_instance_get_by_uuid(RLtuuidR[((s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pytinstance_get_by_uuidÎs
cCsCt|d
|ƒ

j
d|
ƒ
jƒ}|s?tjd|
ƒ
‚
n|S(NR[Rptinstance_id(R^ROtfirstR
tInstanceNotFound(RLRpR[tresult((s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyRoÕs



c
Cs,tj
ƒ}
|
jttjd
|ƒ


|
S(sfCreate a database context manager object.

    : param connection: The database connection string
    R)(Rttransaction_contextR8R0tCONFR9(R)Rd((s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pytcreate_context_manageràs

c
s"tj
ˆƒ
‡f
d
†ƒ
}
|
S(sZ
Decorator to select synchronous or asynchronous reader mode.
    The kwarg argument 'use_slave' defines reader mode. Asynchronous reader
    will be used if 'use_slave' is True and synchronous reader otherwise.
    If 'use_slave' is not specified default value 'False' will be used.
    Wrapped function must have a context in the arguments.
    csŽtj
ˆƒ
}tj|||
Ž
}|d
}|jdtƒ}|rXt|ƒ
j}nt|ƒ
j}|j	|ƒ

ˆ||
ŽSWdQXdS(NRLt	use_slave(
R$tget_wrapped_functiontinspecttgetcallargstgetRER_tasync_R`Rb(RQRctwrapped_funct
keyed_argsRLRytreader_mode(
Re(s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyRnòs




(RgRh(ReRn((
Res;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pytselect_db_reader_modeêsc
s"tj
ˆƒ
‡f
d
†ƒ
}
|
S(s·Decorator to use a writer db context manager.
    The db context manager will be picked from the RequestContext.
    Wrapped function must have a RequestContext in the arguments.
    c
s9t|ƒ
}|j
j|ƒ

ˆ||
|Ž
SWdQXdS(
N(R_twriterRb(RLRQRcRd(
Re(s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyRf	
s

(RgRh(ReRf((
Res;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pytpick_context_manager_writer
sc
s"tj
ˆƒ
‡f
d
†ƒ
}
|
S(s·Decorator to use a reader db context manager.
    The db context manager will be picked from the RequestContext.
    Wrapped function must have a RequestContext in the arguments.
    c
s9t|ƒ
}|j
j|ƒ

ˆ||
|Ž
SWdQXdS(
N(R_R`Rb(RLRQRcRd(
Re(s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyRf
s

(RgRh(ReRf((
Res;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pytpick_context_manager_reader
sc
s"tj
ˆƒ
‡f
d
†ƒ
}
|
S(sÃDecorator to use a reader.allow_async db context manager.
    The db context manager will be picked from the RequestContext.
    Wrapped function must have a RequestContext in the arguments.
    c
s<t|ƒ
}|j
jj|ƒ

ˆ||
|Ž
SWdQXdS(
N(R_R`RaRb(RLRQRcRd(
Re(s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyRf#
s

(RgRh(ReRf((
Res;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyRi
scCs—t||
ƒ}t
|tjƒjd
|
ƒ
jdtƒ

|jdkr“t
|tjƒj	t
tjj|
ktjj|dkƒƒ
jdtƒ

ndS(Ntidtsynchronize_sessionstvault-contegothost(
tservice_getRIR"tServiceROtsoft_deleteREtbinarytComputeNodeRNRt
service_idRˆ(RLRŽtservice((s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pytservice_destroy.
s





cCsIt|t
jƒjd
|
ƒ
}|jƒ}|sEtjd|
ƒ
‚
n|S(NR†RŽ(RIR"RŠRORsR
tServiceNotFound(RLRŽRTRu((s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyR‰=
s


cCsIt|t
jƒjd
|
ƒ
}|jƒ}|sEtjd|
ƒ
‚
n|S(NRpRŽ(RIR"RŠRORsR
R‘(RLtservice_uuidRTRu((s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pytservice_get_by_uuidH
s


cCsˆ|jj
tjjtjtjjƒ
ƒjtjjj	|
ƒ
ƒ
jtjj
d
kƒ
jtjjtƒkƒ
j
tjjƒ
}t|ƒ
S(Ni(RJRTR"RŠRŒRtmintversionRNtin_R?tforced_downRtgroup_byR*(RLtbinariestmin_versions((s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pytservice_get_minimum_versionS
s	
	





cCs=t|t
jƒ}|
dk	r3|jd
|
ƒ
}n|jƒS(Ntdisabled(RIR"RŠR-ROtall(RLRœRT((s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pytservice_get_all_
s
cCs4t|t
jd
dƒ
jdtƒ
jd|
ƒ
jƒS(NRDR>Rœttopic(RIR"RŠRORER(RLRŸ((s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pytservice_get_all_by_topici
s

cCs@t|t
jd
dƒ
jdtƒ
jd|
ƒ
jd|ƒ
jƒS(NRDR>RœRˆRŸ(RIR"RŠRORERs(RLRˆRŸ((s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pytservice_get_by_host_and_topicq
s


cCsCt|t
jƒjd
|
ƒ
}|s9|jdtƒ
}n|jƒS(NRŒRœ(RIR"RŠRORER(RLRŒtinclude_disabledRT((s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pytservice_get_all_by_binaryz
s


cCsŽt|t
jd
dƒ
jddƒ
}|s?|jdtƒ
}n|jt
jt
jjt
jjkƒjt
jj	|
kƒ
j
dƒ
}|jƒS(NRDR>RŒstvault-contegoRœRˆ(RIR"RŠROREtjoinRRˆRNthypervisor_typetdistinctR(RLthv_typeR¢RT((s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyt#service_get_all_computes_by_hv_type‚
s
	





	
cCs[t|t
jd
dƒ
jd|
ƒ
jd|ƒ
jƒ}|sWtjd|
d|ƒ‚
n|S(NRDR>RˆRŒ(RIR"RŠRORsR
tHostBinaryNotFound(RLRˆRŒRu((s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pytservice_get_by_host_and_binary
s


cCs(t|t
jd
dƒ
jd|
ƒ
jƒS(NRDR>Rˆ(RIR"RŠROR(RLRˆ((s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pytservice_get_all_by_host
s
cCsUt|t
jd
dƒ
jd|
ƒ
jddƒ
jƒ}|sQtjd|
ƒ
‚
n|S(NRDR>RˆRŒstvault-contego(RIR"RŠRORsR
tComputeHostNotFound(RLRˆRu((s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pytservice_get_by_compute_host¤
s


cCs°tj
ƒ}|j|
ƒ

y|j|jƒ

Wn|tjk
r«
}
d
|jkr~tj	d|
j
dƒ
d
|
j
d
ƒ
ƒ‚
ntjd|
j
dƒ
d|
j
dƒ
ƒ‚
n
X|S(NRŒRˆRŸ(R"RŠtupdatetsaveRJtdb_exctDBDuplicateEntrytcolumnsR
tServiceBinaryExistsR}tServiceTopicExists(RLtvaluestservice_reft
e((s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pytservice_create±
s










tmax_retriesitretry_on_deadlockcCsTt||
ƒ}d
|krC|d
|j
krCtjƒ|_qCn|j|ƒ

|S(Ntreport_count(R‰R»Rtutcnowtlast_seen_upR®(RLRŽRµR¶((s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pytservice_updateÀ
s




(nt__doc__tcollectionstcopytdatetimeRgR{R%toslo_dbRtoslo_db_apiR
R°toslo_db.sqlalchemyRRRRHtoslo_logRtloggingt
oslo_utilsRRRR	tsixt	six.movesR
t
sqlalchemyR4RRtsqlalchemy.excR
tsqlalchemy.ext.compilerRRRRtsqlalchemy.ormRRRRRRtsqlalchemy.schemaRRtsqlalchemy.sql.expressionRRRRtsqlalchemy.sqlRRR R!t
dmapi.confRKt
dmapi.contexttdmapi.db.sqlalchemyR"t
dmapi.i18nR#R$t
try_importR2R=Rwt	getLoggerR'tLOGRvR7R:R(R-R0R8RERIR^RiR_RjRmRqRoRxR‚R„R…RR‰R“R›RžR R¡R£R¨RªR«R­R¸t
wrap_db_retryRFR¾(((s;/usr/lib/python2.7/dist-packages/dmapi/db/sqlalchemy/api.pyt<module>s¶













































		

.