diff --git a/go/logic/inspect.go b/go/logic/inspect.go
index 0e0c2a3..2d51bd4 100644
--- a/go/logic/inspect.go
+++ b/go/logic/inspect.go
@@ -191,6 +191,9 @@ func (this *Inspector) inspectOriginalAndGhostTables() (err error) {
 			this.migrationContext.MappedSharedColumns.SetEnumToTextConversion(column.Name)
 			this.migrationContext.MappedSharedColumns.SetEnumValues(column.Name, column.EnumValues)
 		}
+		if column.Name == mappedColumn.Name && column.Charset != mappedColumn.Charset {
+			this.migrationContext.MappedSharedColumns.SetCharsetConversion(column.Name, column.Charset, mappedColumn.Charset)
+		}
 	}
 
 	for _, column := range this.migrationContext.UniqueKey.Columns.Columns() {
diff --git a/go/sql/builder.go b/go/sql/builder.go
index 7fe366c..e6a723f 100644
--- a/go/sql/builder.go
+++ b/go/sql/builder.go
@@ -42,6 +42,8 @@ func buildColumnsPreparedValues(columns *ColumnList) []string {
 			token = fmt.Sprintf("ELT(?, %s)", column.EnumValues)
 		} else if column.Type == JSONColumnType {
 			token = "convert(? using utf8mb4)"
+		} else if column.charsetConversion != nil {
+			token = fmt.Sprintf("convert(convert(? using %s) using %s)", column.charsetConversion.FromCharset, column.charsetConversion.ToCharset)
 		} else {
 			token = "?"
 		}
@@ -114,6 +116,8 @@ func BuildSetPreparedClause(columns *ColumnList) (result string, err error) {
 			setToken = fmt.Sprintf("%s=ELT(?, %s)", EscapeName(column.Name), column.EnumValues)
 		} else if column.Type == JSONColumnType {
 			setToken = fmt.Sprintf("%s=convert(? using utf8mb4)", EscapeName(column.Name))
+		} else if column.charsetConversion != nil {
+			setToken = fmt.Sprintf("%s=convert(convert(? using %s) using %s)", EscapeName(column.Name), column.charsetConversion.FromCharset, column.charsetConversion.ToCharset)
 		} else {
 			setToken = fmt.Sprintf("%s=?", EscapeName(column.Name))
 		}
diff --git a/go/sql/types.go b/go/sql/types.go
index 3c4ce5e..bb0489e 100644
--- a/go/sql/types.go
+++ b/go/sql/types.go
@@ -32,6 +32,11 @@ type TimezoneConversion struct {
 	ToTimezone string
 }
 
+type CharsetConversion struct {
+	ToCharset   string
+	FromCharset string
+}
+
 type Column struct {
 	Name                 string
 	IsUnsigned           bool
@@ -40,6 +45,7 @@ type Column struct {
 	EnumValues           string
 	timezoneConversion   *TimezoneConversion
 	enumToTextConversion bool
+	charsetConversion    *CharsetConversion
 	// add Octet length for binary type, fix bytes with suffix "00" get clipped in mysql binlog.
 	// https://github.com/github/gh-ost/issues/909
 	BinaryOctetLength uint
@@ -211,6 +217,14 @@ func (this *ColumnList) SetEnumValues(columnName string, enumValues string) {
 	this.GetColumn(columnName).EnumValues = enumValues
 }
 
+func (this *ColumnList) SetCharsetConversion(columnName string, fromCharset string, toCharset string) {
+	this.GetColumn(columnName).charsetConversion = &CharsetConversion{FromCharset: fromCharset, ToCharset: toCharset}
+}
+
+func (this *ColumnList) IsCharsetConversion(columnName string) bool {
+	return this.GetColumn(columnName).charsetConversion != nil
+}
+
 func (this *ColumnList) String() string {
 	return strings.Join(this.Names(), ",")
 }
diff --git a/localtests/convert-utf8mb4/create.sql b/localtests/convert-utf8mb4/create.sql
index 05f1a13..6d83b31 100644
--- a/localtests/convert-utf8mb4/create.sql
+++ b/localtests/convert-utf8mb4/create.sql
@@ -7,7 +7,7 @@ create table gh_ost_test (
   primary key(id)
 ) auto_increment=1;
 
-insert into gh_ost_test values (null, 'átesting');
+insert into gh_ost_test values (null, 'átesting', '', '');
 
 
 insert into gh_ost_test values (null, 'Hello world, Καλημέρα κόσμε, コンニチハ', 'átesting0', 'initial');
diff --git a/localtests/latin1text-to-utf8mb4/create.sql b/localtests/latin1text-to-utf8mb4/create.sql
index a1447d5..dff7a96 100644
--- a/localtests/latin1text-to-utf8mb4/create.sql
+++ b/localtests/latin1text-to-utf8mb4/create.sql
@@ -5,7 +5,7 @@ create table gh_ost_test (
   primary key(id)
 ) auto_increment=1 charset latin1 collate latin1_swedish_ci;
 
-insert into gh_ost_test values (null, char(128));
+insert into gh_ost_test values (null, char(189));
 
 drop event if exists gh_ost_test;
 delimiter ;;
@@ -18,7 +18,7 @@ create event gh_ost_test
   do
 begin
   insert into gh_ost_test values (null, md5(rand()));
-  insert into gh_ost_test values (null, char(128));
-  update gh_ost_test set t=char(230) order by id desc limit 1;
-  delete from gh_ost_test where t=char(230);
+  insert into gh_ost_test values (null, char(189));
+  update gh_ost_test set t=char(190) order by id desc limit 1;
+  delete from gh_ost_test where t=char(190);
 end ;;