internal: support changing passwords. (#585)

feat(user): support changing passwords.

Author: runkecheng

internal/sql_runner.go

@@ -346,7 +346,7 @@ func CreateUserIfNotExists(sqlRunner SQLRunner, user *apiv1alpha1.MysqlUser, pas
 
 	queries := []Query{
 		getCreateUserQuery(userName, pass, hosts, user.Spec.TLSOptions),
-		// todo: getAlterUserQuery.
+		getAlterUserQuery(userName, pass, hosts),
 	}
 
 	if len(permissions) > 0 {
@@ -373,6 +373,18 @@ func getUserTLSRequire(tlsOption apiv1alpha1.TLSOptions) string {
 	return fmt.Sprintf(" REQUIRE %s", tlsOption.Type)
 }
 
+// Only support changing passwords.
+func getAlterUserQuery(user, pwd string, allowedHosts []string) Query {
+	args := []interface{}{}
+	q := "ALTER USER"
+
+	ids, idsArgs := getUsersIdentification(user, &pwd, allowedHosts)
+	q += ids
+	args = append(args, idsArgs...)
+
+	return NewQuery(q, args...)
+}
+
 func getUsersIdentification(user string, pwd *string, allowedHosts []string) (ids string, args []interface{}) {
 	for i, host := range allowedHosts {
 		// Add comma if more than one allowed hosts are used.