@@ -16,30 +16,30 @@ import (
16
16
17
17
// ConvertDatabaseTable converts database and tables from utf8 to utf8mb4 if it's mysql and set ROW_FORMAT=dynamic
18
18
func ConvertDatabaseTable () error {
19
- if x .Dialect ().URI ().DBType != schemas .MYSQL {
19
+ if xormEngine .Dialect ().URI ().DBType != schemas .MYSQL {
20
20
return nil
21
21
}
22
22
23
- r , err := CheckCollations (x )
23
+ r , err := CheckCollations (xormEngine )
24
24
if err != nil {
25
25
return err
26
26
}
27
27
28
- _ , err = x .Exec (fmt .Sprintf ("ALTER DATABASE `%s` CHARACTER SET utf8mb4 COLLATE %s" , setting .Database .Name , r .ExpectedCollation ))
28
+ _ , err = xormEngine .Exec (fmt .Sprintf ("ALTER DATABASE `%s` CHARACTER SET utf8mb4 COLLATE %s" , setting .Database .Name , r .ExpectedCollation ))
29
29
if err != nil {
30
30
return err
31
31
}
32
32
33
- tables , err := x .DBMetas ()
33
+ tables , err := xormEngine .DBMetas ()
34
34
if err != nil {
35
35
return err
36
36
}
37
37
for _ , table := range tables {
38
- if _ , err := x .Exec (fmt .Sprintf ("ALTER TABLE `%s` ROW_FORMAT=dynamic" , table .Name )); err != nil {
38
+ if _ , err := xormEngine .Exec (fmt .Sprintf ("ALTER TABLE `%s` ROW_FORMAT=dynamic" , table .Name )); err != nil {
39
39
return err
40
40
}
41
41
42
- if _ , err := x .Exec (fmt .Sprintf ("ALTER TABLE `%s` CONVERT TO CHARACTER SET utf8mb4 COLLATE %s" , table .Name , r .ExpectedCollation )); err != nil {
42
+ if _ , err := xormEngine .Exec (fmt .Sprintf ("ALTER TABLE `%s` CONVERT TO CHARACTER SET utf8mb4 COLLATE %s" , table .Name , r .ExpectedCollation )); err != nil {
43
43
return err
44
44
}
45
45
}
@@ -49,11 +49,11 @@ func ConvertDatabaseTable() error {
49
49
50
50
// ConvertVarcharToNVarchar converts database and tables from varchar to nvarchar if it's mssql
51
51
func ConvertVarcharToNVarchar () error {
52
- if x .Dialect ().URI ().DBType != schemas .MSSQL {
52
+ if xormEngine .Dialect ().URI ().DBType != schemas .MSSQL {
53
53
return nil
54
54
}
55
55
56
- sess := x .NewSession ()
56
+ sess := xormEngine .NewSession ()
57
57
defer sess .Close ()
58
58
res , err := sess .QuerySliceString (`SELECT 'ALTER TABLE ' + OBJECT_NAME(SC.object_id) + ' MODIFY SC.name NVARCHAR(' + CONVERT(VARCHAR(5),SC.max_length) + ')'
59
59
FROM SYS.columns SC
0 commit comments