2

私はnhibernate + fluentで作業しています。このコードがあります

FluentConfiguration fc = Fluently.Configure()
            .Database(MySQLConfiguration.Standard.ConnectionString(connectionString).ShowSql()
            .Dialect<NHibernate.Dialect.MySQL5Dialect>().Driver<NHibernate.Driver.MySqlDataDriver>())
            .Mappings(m => m.FluentMappings
                .AddFromAssemblyOf<UsuarioMap>()
                .Conventions.Add(PrimaryKey.Name.Is(a => string.Concat("Id", a.EntityType.Name)))
                .Conventions.Add(ForeignKey.Format((x, y) => string.Concat("Id", y.Name))))
            .ExposeConfiguration(BuildSchema);

これにより、マップ ファイルからマッピングが追加されます。後で、公開された構成を使用してスキーマをエクスポートします。

データベースにトリガーを作成するために特定のファイルを追加する必要があり.hbm.xmlますが、方法がわかりません。.hbm.xmlファイルは既に作成しています。次のようになります

<?xml version="1.0" encoding="utf-8" ?>
<hibernate-mapping xmlns="urn:nhibernate-mapping-2.2">
  <database-object>
    <create>
    CREATE TRIGGER borradoUsuario BEFORE DELETE ON activaciones
    FOR EACH ROW BEGIN set @idUsuario = OLD.IdUsuario;
    SELECT IdHistorialEstado FROM Usuarios WHERE IdUsuario = @idUsuario INTO @IdHistorial;
    SELECT IdDomicilio FROM Usuarios WHERE IdUsuario = @idUsuario INTO @idDomicilio;
    DELETE FROM usuarios WHERE IdUsuario = @idUsuario;
    DELETE FROM domicilios WHERE IdDomicilio = @IdDomicilio;
    DELETE FROM historialestado WHERE IdHistorialEstado = @idHistorial;
    DELETE FROM detallehistorialestado WHERE idHistorialEstado = @idHistorial;
    DELETE FROM inmobiliarias WHERE IdInmobiliaria = @idUsuario;
    DELETE FROM particulares WHERE IdParticular = @idUsuario;
    DELETE FROM moderadores WHERE IdModerador = @idUsuario;
    END
</create>

<drop>
</drop>

ここで助けが得られることを願っています =/

私は別のアプローチに移行しました。いいえ、AbstractAuxiliaryDatabaseObject から拡張されたクラスがあり、スクリプトの作成と削除を認識しています。

public class BorradoUsuarioTrigger : AbstractAuxiliaryDatabaseObject{

    public override string SqlCreateString(Dialect dialect, IMapping p, string defaultCatalog, string defaultSchema){
//The drop is important, because the shema export calls and executes this twice.   


    return @"
        DROP TRIGGER IF EXISTS borradoUsuarioTrigger;
        DELIMITER $$
        CREATE TRIGGER borradoUsuarioTrigger BEFORE DELETE ON activaciones FOR EACH ROW 
        BEGIN 
            DECLARE idHist INTEGER;
            DECLARE idDom INTEGER;
            SET idHist = (SELECT IdHistorialEstado FROM Usuarios WHERE IdUsuario = OLD.IdUsuario);
            SET idDom = (SELECT IdDomicilio FROM Usuarios WHERE IdUsuario = OLD.IdUsuario);
            DELETE FROM domicilios WHERE IdDomicilio = @idDom;
            DELETE FROM historialestado WHERE IdHistorialEstado = @idHist;
            DELETE FROM detallehistorialestado WHERE idHistorialEstado = @idHist;
            DELETE FROM inmobiliarias WHERE IdInmobiliaria = OLD.idUsuario;
            DELETE FROM particulares WHERE IdParticular = OLD.idUsuario;
            DELETE FROM moderadores WHERE IdModerador = OLD.idUsuario;
            DELETE FROM usuarios WHERE IdUsuario = OLD.idUsuario;
        END$$";
    }

    public override string SqlDropString(Dialect dialect, string defaultCatalog, string defaultSchema){
    return @"DROP TRIGGER IF EXISTS borradoUsuarioTrigger";
    }

    public void AddDialectScope(string dialectName){
    throw new NotImplementedException();
    }

    public bool AppliesToDialect(Dialect dialect){
    return true;
    }

    public void SetParameterValues(IDictionary<string, string> parameters){
    base.SetParameterValues(parameters);
    }
}

必要なものに近いと思いますが、まだ機能していません。最も深い例外で次のメッセージが表示されます。

"Parameter @idDom must be defined"

SQL作成スクリプト用にハードコードされた文字列を返そうとしているためだと思いますが、わかりません。誰か助けてもらえますか?

4

1 に答える 1

1

最終的に答えを得ました：

SQLスクリプトを知っているクラスは次のようになります

public class BorradoUsuarioTrigger : AbstractAuxiliaryDatabaseObject
{
    public override string SqlCreateString(Dialect dialect, IMapping p, string defaultCatalog, string defaultSchema){
    //The drop is important, because the shema export calls and executes this twice.   
    this.Parameters.Add("idHist", "(SELECT IdHistorialEstado FROM Usuarios WHERE IdUsuario = OLD.IdUsuario)");
    this.Parameters.Add("idDom", "(SELECT IdDomicilio FROM Usuarios WHERE IdUsuario = OLD.IdUsuario)");

    StringBuilder builder = new StringBuilder();

    builder.AppendLine("DROP TRIGGER IF EXISTS borradoUsuarioTrigger;");
    builder.AppendLine("CREATE TRIGGER borradoUsuarioTrigger BEFORE DELETE ON activaciones FOR EACH ROW ");
    builder.AppendLine("BEGIN ");
    builder.AppendLine("DELETE FROM domicilios WHERE IdDomicilio = " + this.Parameters["idDom"] + "; ");
    builder.AppendLine("DELETE FROM historialestado WHERE IdHistorialEstado = " + this.Parameters["idHist"] + "; ");
    builder.AppendLine("DELETE FROM detallehistorialestado WHERE idHistorialEstado = " + this.Parameters["idHist"] + "; ");
    builder.AppendLine("DELETE FROM inmobiliarias WHERE IdInmobiliaria = OLD.idUsuario; ");
    builder.AppendLine("DELETE FROM particulares WHERE IdParticular = OLD.idUsuario; ");
    builder.AppendLine("DELETE FROM moderadores WHERE IdModerador = OLD.idUsuario; ");
    builder.AppendLine("DELETE FROM usuarios WHERE IdUsuario = OLD.idUsuario; ");
    builder.AppendLine("END ");

    return builder.ToString();
    }

    public override string SqlDropString(Dialect dialect, string defaultCatalog, string defaultSchema)
    {
        return @"DROP TRIGGER IF EXISTS borradoUsuarioTrigger";
    }

    public void AddDialectScope(string dialectName)
    {
        throw new NotImplementedException();
    }

    public bool AppliesToDialect(Dialect dialect)
    {
        return true;
    }

    public void SetParameterValues(IDictionary<string, string> parameters)
    {
        base.SetParameterValues(parameters);
    }
}

流れるように構成すると、次のようになります。

        FluentConfiguration fc = Fluently.Configure()
            .Database(MySQLConfiguration.Standard.ConnectionString(connectionString).ShowSql()
            .Dialect<NHibernate.Dialect.MySQL5Dialect>().Driver<NHibernate.Driver.MySqlDataDriver>())
            .Mappings(m => m.FluentMappings
                .AddFromAssemblyOf<UsuarioMap>()
                .Conventions.Add(PrimaryKey.Name.Is(a => string.Concat("Id", a.EntityType.Name)))
                .Conventions.Add(ForeignKey.Format((x, y) => string.Concat("Id", y.Name))))
            .ExposeConfiguration(conf => conf.AddAuxiliaryDatabaseObject(new BorradoUsuarioTrigger()))
            .ExposeConfiguration(BuildSchema);
于 2012-11-22T14:30:59.170 に答える