backend/server/rhnPackageUpload.py | 11 +++++-
backend/server/rhnSQL/driver_postgresql.py | 5 +--
backend/server/rhnSession.py | 16 ++--------
java/code/src/com/redhat/rhn/common/db/datasource/xml/Package_queries.xml | 2 -
4 files changed, 16 insertions(+), 18 deletions(-)
New commits:
commit 04f725cf90e6c3842ffc0386320ed515804c7863
Author: Jan Pazdziora <jpazdziora(a)redhat.com>
Date: Wed Oct 6 15:05:28 2010 +0200
Fix the logic of the adjusted_port.
Addressing
PythonHeaderParserHandler server.apacheServer::HeaderParserHandler: UnboundLocalError: local variable 'adjusted_port' referenced before assignment
diff --git a/backend/server/rhnSQL/driver_postgresql.py b/backend/server/rhnSQL/driver_postgresql.py
index c6a3311..509c0e2 100644
--- a/backend/server/rhnSQL/driver_postgresql.py
+++ b/backend/server/rhnSQL/driver_postgresql.py
@@ -136,8 +136,9 @@ class Database(sql_base.Database):
def is_connected_to(self, backend, host, port, username, password,
database):
- if not port:
- adjusted_port = -1
+ adjusted_port = -1
+ if port:
+ adjusted_port = port
return (backend == POSTGRESQL) and (self.host == host) and \
(self.port == adjusted_port) and (self.username == username) \
and (self.password == password) and (self.database == database)
commit 893df6d2b534677a9a8772d9e676ab18d045adcb
Author: Jan Pazdziora <jpazdziora(a)redhat.com>
Date: Wed Oct 6 15:55:35 2010 +0200
Load the appropriate backend and initialize it (rhnPackageUpload.py).
diff --git a/backend/server/rhnPackageUpload.py b/backend/server/rhnPackageUpload.py
index 61f40bb..9355d84 100644
--- a/backend/server/rhnPackageUpload.py
+++ b/backend/server/rhnPackageUpload.py
@@ -23,12 +23,12 @@ from spacewalk.common.checksum import getFileChecksum
from spacewalk.common.rhn_rpm import get_header_byte_range
from server import rhnSQL
-from server.importlib import importLib, userAuth, mpmSource, backendOracle, \
+from server.importlib import importLib, userAuth, mpmSource, \
packageImport, errataCache
from server.rhnLib import get_package_path, \
get_package_path_without_package_name
from server.rhnServer import server_packages
-
+from server.rhnSQL.const import ORACLE, POSTGRESQL
def source_match(v1, v2):
""" returns true if both parameters are true, false otherwise """
@@ -161,7 +161,12 @@ def push_package(header, payload_stream, checksum_type, checksum, org_id=None, f
batch = importLib.Collection()
batch.append(pkg)
- backend = backendOracle.OracleBackend()
+ if CFG.DB_BACKEND == ORACLE:
+ from server.importlib.backendOracle import OracleBackend
+ backend = OracleBackend()
+ elif CFG.DB_BACKEND == POSTGRESQL:
+ from server.importlib.backendOracle import PostgresqlBackend
+ backend = PostgresqlBackend()
backend.init()
if force:
commit ed9f60844bedff8d54027f23371f631a8ffdff0f
Author: Jan Pazdziora <jpazdziora(a)redhat.com>
Date: Wed Oct 6 14:40:43 2010 +0200
The AUTONOMOUS_TRANSACTION does not seem to be needed, plus it is not supported in PostgreSQL; removing.
diff --git a/backend/server/rhnSession.py b/backend/server/rhnSession.py
index 1e70d31..1042cba 100644
--- a/backend/server/rhnSession.py
+++ b/backend/server/rhnSession.py
@@ -113,14 +113,10 @@ class Session:
# Old session - clean it up
h = rhnSQL.prepare("""
- DECLARE
- PRAGMA AUTONOMOUS_TRANSACTION;
- BEGIN
- delete from pxtSessions where id = :session_id;
- commit;
- END;
+ delete from pxtSessions where id = :session_id
""")
h.execute(session_id=self.session_id)
+ rhnSQL.commit();
raise ExpiredSessionError("Session not found")
@@ -129,16 +125,12 @@ class Session:
expires = int(time.time()) + self.duration
h = rhnSQL.prepare("""
- DECLARE
- PRAGMA AUTONOMOUS_TRANSACTION;
- BEGIN
insert into PXTSessions (id, web_user_id, expires, value)
- values (:id, :web_user_id, :expires, :value);
- commit;
- END;
+ values (:id, :web_user_id, :expires, :value)
""")
h.execute(id=self.session_id, web_user_id=self.uid,
expires=expires, value='RHNAPP')
+ rhnSQL.commit();
return self
def load(session_string):
commit 85d435ff2c86739f3e1e6c2bfb12447639e48a17
Author: Jan Pazdziora <jpazdziora(a)redhat.com>
Date: Thu Oct 7 13:13:37 2010 +0200
Use current_timestamp instead of the Oracle-specific sysdate in schedule_pkg_for_delete_from_set.
diff --git a/java/code/src/com/redhat/rhn/common/db/datasource/xml/Package_queries.xml b/java/code/src/com/redhat/rhn/common/db/datasource/xml/Package_queries.xml
index fa6e7b0..7dc868b 100644
--- a/java/code/src/com/redhat/rhn/common/db/datasource/xml/Package_queries.xml
+++ b/java/code/src/com/redhat/rhn/common/db/datasource/xml/Package_queries.xml
@@ -1440,7 +1440,7 @@ SELECT P.id, PE.epoch, PE.version, PE.release
<write-mode name="schedule_pkg_for_delete_from_set">
<query params="set_label">
INSERT INTO rhnPackageFileDeleteQueue (path, created)
- (SELECT p.path, sysdate
+ (SELECT p.path, current_timestamp
FROM rhnPackage p, rhnSet s
WHERE p.id = s.element
AND s.label = :set_label