lock/unlock tables for schema snapshot

LordofAvernus · LordofAvernus · commit 51db39ffe789 · 2022-06-22T08:14:06.000Z
diff --git a/driver/oracle/config/db_config.go b/driver/oracle/config/db_config.go
@@ -201,3 +201,12 @@ SELECT dbms_metadata.get_ddl('TABLE','%s','%s') FROM dual`, table, schema))
 	}
 	return query, nil
 }
+
+func (o *OracleDB) LockTablesForSchema() {
+	// tx lock table
+	"LOCK TABLE " + quote(tableId) + " IN ROW SHARE MODE"
+}
+
+func releaseSchemaSnapshotLock() {
+	// roll back connect
+}
diff --git a/driver/oracle/extractor/extractor_oracle.go b/driver/oracle/extractor/extractor_oracle.go
@@ -864,6 +864,7 @@ func (e *ExtractorOracle) CheckAndApplyLowerCaseTableNames() {
 }
 
 func (e *ExtractorOracle) oracleDump() error {
+	
 	// step 1 : todo lock row
 	// query : lock table schema.table in row share mode;
 	if err := e.getSchemaTablesAndMeta(); err != nil {

Original file line number	Diff line number	Diff line change
@@ -201,3 +201,12 @@ SELECT dbms_metadata.get_ddl('TABLE','%s','%s') FROM dual`, table, schema))
`201`	`201`	`}`
`202`	`202`	`return query, nil`
`203`	`203`	`}`
	`204`	`+`
	`205`	`+func (o *OracleDB) LockTablesForSchema() {`
	`206`	`+ // tx lock table`
	`207`	`+ "LOCK TABLE " + quote(tableId) + " IN ROW SHARE MODE"`
	`208`	`+}`
	`209`	`+`
	`210`	`+func releaseSchemaSnapshotLock() {`
	`211`	`+ // roll back connect`
	`212`	`+}`
Original file line number	Diff line number	Diff line change
`@@ -864,6 +864,7 @@ func (e *ExtractorOracle) CheckAndApplyLowerCaseTableNames() {`
`864`	`864`	`}`
`865`	`865`
`866`	`866`	`func (e *ExtractorOracle) oracleDump() error {`
	`867`	`+`
`867`	`868`	`// step 1 : todo lock row`
`868`	`869`	`// query : lock table schema.table in row share mode;`
`869`	`870`	`if err := e.getSchemaTablesAndMeta(); err != nil {`