diff --git a/object/syncer_public_api.go b/object/syncer_public_api.go index 7413c769..ac65c03e 100644 --- a/object/syncer_public_api.go +++ b/object/syncer_public_api.go @@ -14,10 +14,7 @@ package object -import ( - "errors" - "fmt" -) +import "fmt" func getDbSyncerForUser(user *User) (*Syncer, error) { syncers, err := GetSyncers("admin") @@ -41,11 +38,10 @@ func getEnabledSyncerForOrganization(organization string) (*Syncer, error) { for _, syncer := range syncers { if syncer.Organization == organization && syncer.IsEnabled { - syncer.initAdapter() return syncer, nil } } - return nil, errors.New("no enabled syncer found") + return nil, nil } func AddUserToOriginalDatabase(user *User) error { @@ -54,6 +50,10 @@ func AddUserToOriginalDatabase(user *User) error { return err } + if syncer == nil { + return nil + } + updatedOUser := syncer.createOriginalUserFromUser(user) _, err = syncer.addUser(updatedOUser) if err != nil { @@ -69,6 +69,9 @@ func UpdateUserToOriginalDatabase(user *User) error { if err != nil { return err } + if syncer == nil { + return nil + } newUser, err := GetUser(user.GetId()) if err != nil { diff --git a/object/syncer_user.go b/object/syncer_user.go index 22e2d24e..a592e3f8 100644 --- a/object/syncer_user.go +++ b/object/syncer_user.go @@ -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