Ausführen von SQL mit einer ArcSDE-Verbindung
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 an die Benutzer 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 (Wahr) oder fehlgeschlagen ist (Keine).
Achtung:- ArcSDE- und GDB-Systemtabellen dürfen nur mit der ArcGIS-Software geändert werden. Diese Systemtabellen können beschädigt werden, wenn sie direkt mit SQL bearbeitet werden.
- Die Bearbeitung versionierter Daten per SQL sollte nur über versionierte Sichten erfolgen.
- Bei Geodatabases, die in einem relationalen Datenbankmanagementsystem (DBMS) mit DBMS-Datentypen und -Tabellenformaten implementiert sind, können Sie die SQL des DBMS nutzen, um mit den in der Datenbank gespeicherten Informationen zu arbeiten.
- Erfolgt der Zugriff auf die Informationen in einer Geodatabase über SQL, können externe Anwendungen auf die Tabellendaten zugreifen, die von der Geodatabase verwaltet werden. Bei diesen externen Anwendungen kann es sich um nicht räumliche Datenbankanwendungen oder benutzerdefinierte räumliche Anwendungen handeln, die in einer anderen Umgebung als ArcObjects entwickelt wurden. Wenn Sie über SQL auf die Geodatabase zugreifen, stehen jedoch nicht alle Geodatabase-Funktionen zur Verfügung, zum Beispiel Topologie, Netzwerke, Terrains oder andere Klassen- bzw. Workspace-Erweiterungen.
- DBMS-Funktionen wie Trigger und gespeicherte Prozeduren können u. U. zur Verwaltung von Beziehungen zwischen Tabellen verwendet werden, die für bestimmte Geodatabase-Funktionen erforderlich sind. Wenn Sie jedoch die SQL-Befehle in der Datenbank ausführen, ohne diese zusätzliche Funktionalität zu berücksichtigen (z.B. beim Einfügen von Datensätzen in eine Business-Tabelle mit einer INSERT-Anweisung), wird die Geodatabase-Funktionalität umgangen und die Beziehungen zwischen den Daten in der Geodatabase können beschädigt werden.
- Lesen Sie möglichst in der ArcSDE- und Geodatabase-Dokumentation alle Informationen zur Verwendung von SQL bei ArcSDE- bzw. GDB-Objekten im DBMS, bevor Sie auf ArcSDE- oder GDB-Objekte zugreifen bzw. diese bearbeiten.
|
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.  Hinweis:Ein COMMIT kann jedoch auch auftreten, wenn die Verbindung mit ArcSDE beendet wird. (Die DBMS-Dokumentation enthält Informationen dazu, wie einzelne DBMS mit einer Verbindungsunterbrechung während einer Transaktion umgehen.) |
|
execute(sql_statement) |
Sendet die SQL-Anweisung über eine ArcSDE-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 ArcSDE-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 ArcSDE-Transaktionsmodell. Transaktionen sind eine Eigenschaft der ArcSDE-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 ArcSDE-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 ArcSDE 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 (autocommit-Intervall) 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
import arcpy
from arcpy import env
import sys
try:
# Make data path relative
#
env.workspace = sys.path[0]
# Two ways to create the object, which also creates the connection to ArcSDE.
# Using the first method, pass a set of strings containing the connection properties:
# <serverName>,<portNumber>,<version>,<userName>,<password>
# sdeConn = arcpy.ArcSDESQLExecute("gpserver3","5151","#","toolbox","toolbox")
# Using the second method pass the path to a valid ArcSDE connection file
#
sdeConn = arcpy.ArcSDESQLExecute("data\Connection to GPSERVER3.sde")
# Get the SQL statements, separated by ; from a text string.
#
SQLStatement = arcpy.GetParameterAsText(0)
SQLStatementList = SQLStatement.split(";")
print "+++++++++++++++++++++++++++++++++++++++++++++\n"
# For each SQL statement passed in, execute it.
#
for sql in SQLStatementList:
print "Execute SQL Statement: " + sql
try:
# Pass the SQL statement to the database.
#
sdeReturn = sdeConn.execute(sql)
except Exception, ErrorDesc:
print ErrorDesc
sdeReturn = 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(sdeReturn, list):
print "Number of rows returned by query: " + str(len(sdeReturn)), "rows"
for row in sdeReturn:
print row
print "+++++++++++++++++++++++++++++++++++++++++++++\n"
else:
# If the return value was not a list, the statement was most likely a DDL statment.
# Check its status.
if sdeReturn == True:
print "SQL statement: " + sql + " ran sucessfully."
print "+++++++++++++++++++++++++++++++++++++++++++++\n"
else:
print "SQL statement: " + sql + " FAILED."
print "+++++++++++++++++++++++++++++++++++++++++++++\n"
except Exception, ErrorDesc:
print Exception, ErrorDesc
except:
print "Problem executing SQL."
# WARNING - DO NOT USE ON VERSIONED TABLES OR FEATURE CLASSES.
# DO NOT USE ON ANY ArcSDE or GDB SYSTEM TABLES.
# DOING SO MAY RESULT IN DATA CORRUPTION.
import arcpy
from arcpy import env
import sys
try:
# Make data path relative (not relevant unless data is moved here and paths modified)
#
env.workspace = sys.path[0]
#Column name:value that should be in the record.
#
SQLvalues = {"STREET_NAM":"'EUREKA'"}
#Value that is incorrect if found in the above column.
#
badVal = "'EREKA'"
#List of tables to look in for the bad value.
#
tableList = ["streetaddresses_blkA","streetaddresses_blkB", "streetaddresses_blkC"]
# Two ways to create the object, which also creates the connection to ArcSDE.
# Using the first method, pass a set of strings containing the connection properties:
# <serverName>,<portNumber>,<version>,<userName>,<password>
#
sdeConn = arcpy.ArcSDESQLExecute("gpserver3","5151","#","toolbox","toolbox")
# Using the second method pass the path to a valid ArcSDE connection file
# sdeConn = arcpy.ArcSDESQLExecute("data\Connection to GPSERVER3.sde")
for tbl in tableList:
print "++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++"
for col, val in SQLvalues.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 " + tbl + " for bad data: Column:" + col + " Value: " + badVal
try:
sql = "select OBJECTID," + col + " from " + tbl + " where " + col + " = " + badVal
print "Attempt to execute SQL Statement: " + sql
sdeReturn = sdeConn.execute(sql)
except Exception, ErrorDesc:
print ErrorDesc
sdeReturn = False
if isinstance(sdeReturn, list):
if len(sdeReturn) > 0:
print "Identified " + str(len(sdeReturn)) + " rows with incorrect data. Starting transaction for update."
# Start the transaction
#
sdeConn.startTransaction()
print "Transaction started....."
# Perform the update
#
try:
sql = "update " + tbl + " set " + col + "=" + str(val) + " where " + col + " = " + badVal
print "Changing bad value: " + badVal + " to the good value: " + val + " using update statement:\n " + sql
sdeReturn = sdeConn.execute(sql)
except Exception, ErrorDesc:
print ErrorDesc
sdeReturn = False
# If the update completed sucessfully, commit the changes. If not, rollback.
#
if sdeReturn == True:
print "Update statement: \n" + sql + " ran successfully."
# Commit the changes
#
sdeConn.commitTransaction()
print "Commited Transaction"
# List the changes.
#
try:
print "Displaying updated rows for visual inspection."
sql = "select OBJECTID," + col + " from " + tbl + " where " + col + " = " + val
print "Executing SQL Statement: \n" + sql
sdeReturn = sdeConn.execute(sql)
except Exception, ErrorDesc:
print ErrorDesc
sdeReturn = False
if isinstance(sdeReturn, list):
print len(sdeReturn), "rows"
for row in sdeReturn:
print row
print "+++++++++++++++++++++++++++++++++++++++++++++\n"
else:
if sdeReturn == True:
print "SQL statement: \n" + sql + "\nran successfully."
print "+++++++++++++++++++++++++++++++++++++++++++++\n"
else:
print "SQL statement: \n" + sql + "\nFAILED."
print "+++++++++++++++++++++++++++++++++++++++++++++\n"
print "+++++++++++++++++++++++++++++++++++++++++++++\n"
else:
print "SQL statement: \n" + sql + "\nFAILED. Rolling back all changes."
# Rollback changes
#
sdeConn.rollbackTransaction()
print "Rolled back any changes."
print "+++++++++++++++++++++++++++++++++++++++++++++\n"
else:
print "No records required updating."
# Disconnect and exit
del sdeConn
print "++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++"
except Exception, ErrorDesc:
print Exception, ErrorDesc
except:
print "Problem executing SQL."