mirror of
https://github.com/casdoor/casdoor.git
synced 2025-07-03 20:50:19 +08:00
feat: fix the bug that sycner does not initialize (#1924)
This commit is contained in:
@ -14,7 +14,10 @@
|
||||
|
||||
package object
|
||||
|
||||
import "fmt"
|
||||
import (
|
||||
"errors"
|
||||
"fmt"
|
||||
)
|
||||
|
||||
func getDbSyncerForUser(user *User) (*Syncer, error) {
|
||||
syncers, err := GetSyncers("admin")
|
||||
@ -38,10 +41,11 @@ func getEnabledSyncerForOrganization(organization string) (*Syncer, error) {
|
||||
|
||||
for _, syncer := range syncers {
|
||||
if syncer.Organization == organization && syncer.IsEnabled {
|
||||
syncer.initAdapter()
|
||||
return syncer, nil
|
||||
}
|
||||
}
|
||||
return nil, nil
|
||||
return nil, errors.New("no enabled syncer found")
|
||||
}
|
||||
|
||||
func AddUserToOriginalDatabase(user *User) error {
|
||||
@ -50,10 +54,6 @@ func AddUserToOriginalDatabase(user *User) error {
|
||||
return err
|
||||
}
|
||||
|
||||
if syncer == nil {
|
||||
return nil
|
||||
}
|
||||
|
||||
updatedOUser := syncer.createOriginalUserFromUser(user)
|
||||
_, err = syncer.addUser(updatedOUser)
|
||||
if err != nil {
|
||||
@ -69,9 +69,6 @@ func UpdateUserToOriginalDatabase(user *User) error {
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
if syncer == nil {
|
||||
return nil
|
||||
}
|
||||
|
||||
newUser, err := GetUser(user.GetId())
|
||||
if err != nil {
|
||||
|
@ -107,7 +107,7 @@ func (syncer *Syncer) updateUser(user *OriginalUser) (bool, error) {
|
||||
delete(m, syncer.TablePrimaryKey)
|
||||
setString := syncer.getSqlSetStringFromMap(m)
|
||||
|
||||
sql := fmt.Sprintf("update %s set %s where %s = %s", syncer.getTable(), setString, syncer.TablePrimaryKey, pkValue)
|
||||
sql := fmt.Sprintf("update %s set %s where %s = '%s'", syncer.getTable(), setString, syncer.TablePrimaryKey, pkValue)
|
||||
res, err := syncer.Adapter.Engine.Exec(sql)
|
||||
if err != nil {
|
||||
return false, err
|
||||
|
Reference in New Issue
Block a user