Bei nicht versionierten Tabellen empfiehlt sich in vielen Fällen die Abfrage einer Tabelle in einer Datenbank per SQL (Structured Query Language) anstatt mit einem Geoverarbeitungswerkzeug. Das ArcSDESQLExecute-Objekt unterstützt die meisten SQL-Anweisungen und gibt die Ergebnisse dieser Anweisungen zurück. Bei Anweisungen, die Tabellenzeilen zurückgeben, liefert das Objekt eine Listenauflistung. Bei Anweisungen, die keine Zeilen zurückgeben, zeigt das Objekt an, ob die Anweisung erfolgreich war (True) oder fehlgeschlagen ist (None). Anweisungen, die einen einzigen Wert aus einer einzigen Zeile zurückgeben, geben diesen Wert als entsprechenden Typ (string, float usw.) aus.
| Eigenschaft | |
|---|---|
transactionAutoCommit | Das autocommit-Intervall. Sie können mit dieser Eigenschaft festlegen, dass nach der Bearbeitung einer bestimmten Anzahl von Features jeweils ein COMMIT durchgeführt wird. |
| Methoden | |
|---|---|
commitTransaction() | Es werden keine DML-Anweisungen übernommen, bevor die commitTransaction-Methode aufgerufen wird. |
execute(sql_statement) | Sendet die SQL-Anweisung über eine Enterprise-Geodatabase-Verbindung an die Datenbank. Falls "execute" außerhalb einer Transaktion ausgeführt wird, findet automatisch ein COMMIT statt, sobald die SQL-DML-Anweisung (INSERT, UPDATE, DELETE) ausgeführt wurde. |
rollbackTransaction() | Alle DML-Vorgänge werden bis zum letzten COMMIT rückgängig gemacht. |
startTransaction() | Um zu steuern, wann die Änderungen in die Datenbank übernommen werden, rufen Sie die Methode startTransaction vor der Methode "execute" auf. Hierdurch wird die Transaktion gestartet und alle DML-Anweisungen werden erst übernommen, wenn die Methode commitTransaction aufgerufen wird. |
Die execute-Methode sendet die SQL-Anweisung über eine Enterprise-Geodatabase-Verbindung an die Datenbank. Falls "execute" außerhalb einer Transaktion ausgeführt wird, findet automatisch ein COMMIT statt, sobald die SQL-DML-Anweisung (INSERT, UPDATE, DELETE) ausgeführt wurde.
ArcSDESQLExecute unterstützt das Geodatabase-Transaktionsmodell. Transaktionen sind eine Eigenschaft der Enterprise-Geodatabase-Verbindung und binden Vorgänge, sodass ganze Änderungssätze in ihrer Gesamtheit erfasst oder abgelehnt werden. Wenn etwa eine Gruppe von Flurstücken in einer bestimmten Reihenfolge aktualisiert wird, können Sie mit einer Transaktion den Anfang und das Ende der Änderungen festlegen, sodass alle Änderungen zusammen zurückgeschrieben werden. Falls ein Änderungssatz nicht eingefügt werden kann, wird die gesamte Transaktion abgelehnt. Alle Transaktionen werden beendet, wenn die Verbindung unterbrochen wird. ArcSDESQLExecute verwendet die bereitgestellten Enterprise-Geodatabase-API-Funktionen, um Transaktionen zu starten, zu übernehmen und rückgängig zu machen.
Falls Sie steuern möchten, wann die Änderungen in die Datenbank übernommen werden, rufen Sie die Methode startTransaction vor der Methode "Execute" auf. Hierdurch wird die Transaktion gestartet und alle DML-Anweisungen werden erst übernommen, wenn die Methode commitTransaction aufgerufen wird. Ein COMMIT kann jedoch auch auftreten, wenn die Verbindung mit der Enterprise-Geodatabase beendet wird. (Die DBMS-Dokumentation enthält Informationen dazu, wie einzelne DBMS mit einer Verbindungsunterbrechung während einer Transaktion umgehen.) Innerhalb einer Transaktion können alle DML-Vorgänge bis zum vorherigen COMMIT rückgängig gemacht werden.
transactionAutoCommit steht als Eigenschaft für das Intervall zwischen automatischen COMMITS zur Verfügung. Sie können mit dieser Eigenschaft festlegen, dass nach der Bearbeitung einer bestimmten Anzahl von Features jeweils ein COMMIT durchgeführt wird.
Informationen zum Schreiben von SQL-Anweisungen finden Sie in Ihrem spezifischen DBMS-SQL-Referenzhandbuch.
Beispiele
Ausführen einer Liste von SQL-Anweisungen
import sys
import arcpy
try:
# Make data path relative
arcpy.env.workspace = sys.path[0]
# Two ways to create the object, which also creates the
# connection to the enterprise geodatabase.
# Using the first method, pass a set of strings containing
# the connection properties:
# <serverName>, <portNumber>, <version>, <userName>, <password>
# arcpy.ArcSDESQLExecute("gpserver3","5151","#","toolbox","toolbox")
# Using the second method pass the path to a valid connection file
egdb_conn = arcpy.ArcSDESQLExecute(r"data\Connection to GPSERVER3.sde")
# Get the SQL statements, separated by ; from a text string.
sql_statement = arcpy.GetParameterAsText(0)
sql_statement_list = sql_statement.split(";")
print("+++++++++++++++++++++++++++++++++++++++++++++\n")
# For each SQL statement passed in, execute it.
for sql in sql_statement_list:
print("Execute SQL Statement: {0}".format(sql))
try:
# Pass the SQL statement to the database.
egdb_return = egdb_conn.execute(sql)
except Exception as err:
print(err)
egdb_return = False
# If the return value is a list (a list of lists), display
# each list as a row from the table being queried.
if isinstance(egdb_return, list):
print("Number of rows returned by query: {0} rows".format(
len(egdb_return)))
for row in egdb_return:
print(row)
print("+++++++++++++++++++++++++++++++++++++++++++++\n")
else:
# If the return value was not a list, the statement was
# most likely a DDL statement. Check its status.
if egdb_return == True:
print("SQL statement: {0} ran successfully.".format(sql))
else:
print("SQL statement: {0} FAILED.".format(sql))
print("+++++++++++++++++++++++++++++++++++++++++++++\n")
except Exception as err:
print(err)
Bedingte Aktualisierung mit einer Transaktion
# WARNING - DO NOT USE ON VERSIONED TABLES OR FEATURE CLASSES.
# DO NOT USE ON ANY enterprise geodatabase SYSTEM TABLES.
# DOING SO MAY RESULT IN DATA CORRUPTION.
import sys
import arcpy
try:
# Make data path relative (not relevant unless data is moved
# here and paths modified)
arcpy.env.workspace = sys.path[0]
# Column name:value that should be in the record.
sql_values = {"STREET_NAM": "'EUREKA'"}
# Value that is incorrect if found in the above column.
bad_val = "'EREKA'"
#List of tables to look in for the bad value.
tables = ["streetaddresses_blkA", "streetaddresses_blkB",
"streetaddresses_blkC"]
# Two ways to create the object, which also creates the connection
# to the enterprise geodatabase.
# Using the first method, pass a set of strings containing the
# connection properties:
# <serverName>, <portNumber>, <version>, <userName>, <password>
egdb_conn = arcpy.ArcSDESQLExecute("gpserver3", "5151", "#",
"toolbox", "toolbox")
# Using the second method pass the path to a valid enterprise geodatabase connection file
# arcpy.ArcSDESQLExecute("data\Connection to GPSERVER3.sde")
for tbl in tables:
print("+++++++++++++++++++++++++++++++++++++++++++++++++++++++++++")
for col, val in list(sql_values.items()):
print("+++++++++++++++++++++++++++++++++++++++++++++++++++++++++++")
# Check for the incorrect value in the column for the
# specific rows. If the table contains the incorrect value,
# correct it using the update SQL statement.
print("Analyzing table {0} for bad data: "
"Column:{1} Value: {2}".format(tbl, col, bad_val))
try:
sql = "select OBJECTID,{0} from {1} where {0} = {2}".format(
col, tbl, bad_val)
print("Attempt to execute SQL Statement: {0}".format(sql))
egdb_return = egdb_conn.execute(sql)
except Exception as err:
print(err)
egdb_return = False
if isinstance(egdb_return, list):
if len(egdb_return) > 0:
print("Identified {0} rows with incorrect data. Starting "
"transaction for update.".format(len(egdb_return)))
# Start the transaction
egdb_conn.startTransaction()
print("Transaction started...")
# Perform the update
try:
sql = "update {0} set {1}={2} where {1} = {3}".format(
tbl, col, val, bad_val)
print("Changing bad value: {0} to the good value: "
"{1} using update statement:\n {2}".format(
bad_val, val, sql))
egdb_return = egdb_conn.execute(sql)
except Exception as err:
print(err)
egdb_return = False
# If the update completed successfully, commit the
# changes. If not, rollback.
if egdb_return == True:
print("Update statement: \n"
"{0} ran successfully.".format(sql))
# Commit the changes
egdb_conn.commitTransaction()
print("Committed Transaction")
# List the changes.
try:
print("Displaying updated rows for "
"visual inspection.")
sql = "select OBJECTID" + \
",{0} from {1} where {0} = {2}".format(
col, tbl, val)
print("Executing SQL Statement: \n{0}".format(sql))
egdb_return = egdb_conn.execute(sql)
except Exception as err:
print(err)
egdb_return = False
if isinstance(egdb_return, list):
print("{0} rows".format(len(egdb_return)))
for row in egdb_return:
print(row)
print("++++++++++++++++++++++++++++++++++++++++\n")
else:
if egdb_return == True:
print("SQL statement: \n{0}\n"
"ran successfully.".format(sql))
else:
print("SQL statement: \n{0}\n"
"FAILED.".format(sql))
print("++++++++++++++++++++++++++++++++++++++++\n")
print("++++++++++++++++++++++++++++++++++++++++\n")
else:
print("SQL statement: \n{0}\nFAILED. "
"Rolling back all changes.".format(sql))
# Rollback changes
egdb_conn.rollbackTransaction()
print("Rolled back any changes.")
print("++++++++++++++++++++++++++++++++++++++++\n")
else:
print "No records required updating."
# Disconnect and exit
del egdb_conn
print("+++++++++++++++++++++++++++++++++++++++++++++++++++++++++++")
except Exception as err:
print(err)