fix: create index failed when table name has -. (#793) (#795)

OpenIM-Robot · FGadvancer · web-flow · commit 61d6b6e652c4 · 2024-11-27T17:01:10.000+08:00
Co-authored-by: OpenIM-Gordon &lt;46924906+FGadvancer@users.noreply.github.com&gt;
diff --git a/pkg/db/chat_log_model.go b/pkg/db/chat_log_model.go
@@ -66,11 +66,11 @@ func (d *DataBase) initChatLog(ctx context.Context, conversationID string) error
 		if result := d.conn.Exec(createTableSQL); result.Error != nil {
 			return errs.WrapMsg(result.Error, "Create table failed", "table", tableName)
 		}
-		result := d.conn.Exec(fmt.Sprintf("CREATE INDEX %s ON %s (seq)", "index_seq_"+conversationID, tableName))
+		result := d.conn.Exec(fmt.Sprintf("CREATE INDEX `%s` ON %s (seq)", "index_seq_"+conversationID, tableName))
 		if result.Error != nil {
 			return errs.WrapMsg(result.Error, "Create index_seq failed", "table", tableName, "index", "index_seq_"+conversationID)
 		}
-		result = d.conn.Exec(fmt.Sprintf("CREATE INDEX %s ON %s (send_time)", "index_send_time_"+conversationID, tableName))
+		result = d.conn.Exec(fmt.Sprintf("CREATE INDEX `%s` ON %s (send_time)", "index_send_time_"+conversationID, tableName))
 		if result.Error != nil {
 			return errs.WrapMsg(result.Error, "Create index_send_time failed", "table", tableName, "index", "index_send_time_"+conversationID)
 		}

Original file line number	Diff line number	Diff line change
`@@ -66,11 +66,11 @@ func (d *DataBase) initChatLog(ctx context.Context, conversationID string) error`
`66`	`66`	`if result := d.conn.Exec(createTableSQL); result.Error != nil {`
`67`	`67`	`return errs.WrapMsg(result.Error, "Create table failed", "table", tableName)`
`68`	`68`	`}`
`69`		`- result := d.conn.Exec(fmt.Sprintf("CREATE INDEX %s ON %s (seq)", "index_seq_"+conversationID, tableName))`
	`69`	+ result := d.conn.Exec(fmt.Sprintf("CREATE INDEX `%s` ON %s (seq)", "index_seq_"+conversationID, tableName))
`70`	`70`	`if result.Error != nil {`
`71`	`71`	`return errs.WrapMsg(result.Error, "Create index_seq failed", "table", tableName, "index", "index_seq_"+conversationID)`
`72`	`72`	`}`
`73`		`- result = d.conn.Exec(fmt.Sprintf("CREATE INDEX %s ON %s (send_time)", "index_send_time_"+conversationID, tableName))`
	`73`	+ result = d.conn.Exec(fmt.Sprintf("CREATE INDEX `%s` ON %s (send_time)", "index_send_time_"+conversationID, tableName))
`74`	`74`	`if result.Error != nil {`
`75`	`75`	`return errs.WrapMsg(result.Error, "Create index_send_time failed", "table", tableName, "index", "index_send_time_"+conversationID)`
`76`	`76`	`}`