Revision 197 trunk/org.gvsig.mssqlserver/org.gvsig.mssqlserver.provider/src/main/java/org/gvsig/mssqlserver/dal/operations/MSSQLServerPerformChangesOperation.java
| MSSQLServerPerformChangesOperation.java | ||
|---|---|---|
| 10 | 10 |
import org.gvsig.fmap.dal.feature.spi.FeatureReferenceProviderServices; |
| 11 | 11 |
import org.gvsig.fmap.dal.feature.spi.FeatureStoreProvider; |
| 12 | 12 |
import org.gvsig.fmap.dal.store.jdbc2.JDBCHelper; |
| 13 |
import org.gvsig.fmap.dal.store.jdbc2.OperationsFactory.TableReference; |
|
| 13 | 14 |
import org.gvsig.fmap.dal.store.jdbc2.spi.JDBCSQLBuilderBase; |
| 14 | 15 |
import org.gvsig.fmap.dal.store.jdbc2.spi.operations.PerformChangesOperation; |
| 15 | 16 |
import org.gvsig.mssqlserver.dal.MSSQLServerHelper; |
| 16 | 17 |
import org.gvsig.mssqlserver.dal.MSSQLServerSQLBuilder.MSSQLServerCreateIndexBuilder; |
| 17 | 18 |
|
| 19 |
@SuppressWarnings("UseSpecificCatch")
|
|
| 18 | 20 |
public class MSSQLServerPerformChangesOperation extends PerformChangesOperation {
|
| 19 | 21 |
|
| 20 | 22 |
public MSSQLServerPerformChangesOperation(JDBCHelper helper) {
|
| 21 |
this(helper, null, null, null, null, null, null, null, null);
|
|
| 23 |
this(helper, null, null, null, null, null, null); |
|
| 22 | 24 |
} |
| 23 | 25 |
|
| 24 | 26 |
public MSSQLServerPerformChangesOperation(JDBCHelper helper, |
| 25 |
String dbName, |
|
| 26 |
String schemaName, |
|
| 27 |
String tableName, |
|
| 27 |
TableReference table, |
|
| 28 | 28 |
FeatureType featureType, |
| 29 | 29 |
Iterator<FeatureReferenceProviderServices> deleteds, |
| 30 | 30 |
Iterator<FeatureProvider> inserteds, |
| 31 | 31 |
Iterator<FeatureProvider> updateds, |
| 32 | 32 |
Iterator<FeatureStoreProvider.FeatureTypeChanged> featureTypesChanged) {
|
| 33 |
super(helper, dbName, schemaName, tableName, featureType, deleteds, inserteds, updateds, featureTypesChanged);
|
|
| 33 |
super(helper, table, featureType, deleteds, inserteds, updateds, featureTypesChanged);
|
|
| 34 | 34 |
} |
| 35 | 35 |
|
| 36 | 36 |
protected MSSQLServerHelper getHelper() {
|
| ... | ... | |
| 39 | 39 |
|
| 40 | 40 |
@Override |
| 41 | 41 |
protected List<String> buildCreateIndexSQL( |
| 42 |
String database, |
|
| 43 |
String schema, |
|
| 44 |
String table, |
|
| 42 |
TableReference table, |
|
| 45 | 43 |
FeatureType original, |
| 46 | 44 |
FeatureType target |
| 47 | 45 |
) {
|
| ... | ... | |
| 64 | 62 |
try {
|
| 65 | 63 |
return this.getHelper().createOrUpdateSpatialIndexSql( |
| 66 | 64 |
this.getConnection(), |
| 67 |
database,
|
|
| 68 |
schema,
|
|
| 69 |
table, |
|
| 65 |
table.getDatabase(),
|
|
| 66 |
table.getSchema(),
|
|
| 67 |
table.getTable(),
|
|
| 70 | 68 |
attrTarget.getName() |
| 71 | 69 |
); |
| 72 | 70 |
} catch (Exception ex) {
|
| ... | ... | |
| 78 | 76 |
create_index.if_not_exist(); |
| 79 | 77 |
create_index.name("idx_" + table + "_" + attrTarget.getName());
|
| 80 | 78 |
create_index.column(attrTarget.getName()); |
| 81 |
create_index.table().database(database).schema(schema).name(table); |
|
| 79 |
create_index.table() |
|
| 80 |
.database(table.getDatabase()) |
|
| 81 |
.schema(table.getSchema()) |
|
| 82 |
.name(table.getTable()); |
|
| 82 | 83 |
return create_index.toStrings(); |
| 83 | 84 |
} |
| 84 | 85 |
} |
Also available in: Unified diff