Hi, i need to join two datasource that have the same common column "DATA_ORA_PRESENTAZIONE"

Neither works:

$join = new Join( $this->dataStore("domande_presentate_pergiorno"), $this->dataStore("domande_immatricolate"), ["DATA_ORA_PRESENTAZIONE"=>"DATA_ORA_PRESENTAZIONE"]);
        $join->pipe($this->dataStore('domande_presentate_con_immatricolazioni'));

        $newDatastore = $this->dataStore("domande_presentate_pergiorno")->join($this->dataStore("domande_immatricolate"), ["DATA_ORA_PRESENTAZIONE"=>"DATA_ORA_PRESENTAZIONE"]);
        $newDatastore->pipe($this->dataStore('domande_presentate_con_immatricolazioni2'));

First datasource

        $this->src("default")
            ->query("SELECT DATA_ORA_PRESENTAZIONE .....")
            ->pipe(new DateTimeFormat([
                "DATA_ORA_PRESENTAZIONE" => [
                    "from" => "d/m/Y H:i:s",
                    "to"   => "F j, Y",
                ],
            ]))
            ->pipe(new Group([
                "by"    => [
                    "DATA_ORA_PRESENTAZIONE",
                ],
                "count" => "TOTALE_PER_GIORNO",
            ]))
            ->pipe(new AccumulativeColumn([
                'TOTALE_DOMANDE' => 'TOTALE_PER_GIORNO',
            ]))
            ->pipe(new ColumnRename([
                "DATA_ORA_PRESENTAZIONE" => "Giorno",
                "TOTALE_PER_GIORNO"      => "Numero di domande",
            ]))
            ->pipe($this->dataStore("domande_presentate_pergiorno"));

Second datasource

$this->src("default")
            ->query("SELECT max(DATA_ORA_PRESENTAZIONE) DATA_ORA_PRESENTAZIONE ...")
            ->pipe(new DateTimeFormat([
                "DATA_ORA_PRESENTAZIONE" => [
                    "from" => "d/m/Y H:i:s",
                    "to"   => "F j, Y",
                ],
            ]))
            ->pipe(new Group([
                "by"    => [
                    "DATA_ORA_PRESENTAZIONE",
                ],
                "count" => "TOTALE_IMMATRICOLATI_PER_GIORNO",
            ]))
            ->pipe(new ColumnRename([
                "DATA_ORA_PRESENTAZIONE"          => "Giorno",
                "TOTALE_IMMATRICOLATI_PER_GIORNO" => "Numero di domande risultate immatricolate",
            ]))
            ->pipe($this->dataStore("domande_immatricolate"));

What is wrong?

Maybe try this

$join = new Join( $this->dataStore("domande_presentate_pergiorno"), $this->dataStore("domande_immatricolate"), array("DATA_ORA_PRESENTAZIONE"=>"DATA_ORA_PRESENTAZIONE"));
        $join->pipe($this->dataStore('domande_presentate_con_immatricolazioni'));

Im sure you are running php 5.4+ but i just thought I would throw it out there.

I'm running PHP 5.6.30 The script you suggested doesn't work. It seems that it doesn't find the key on the two datasource to join. How I can inspect the problem?

I have already tried to comment the columnRename process without success (the example was a mix, my fault). Now I have tried to map array("Giorno"=>"Giorno") in the Join without success :(

It seems that the $this->container[i]["data"] is empty for both array in Join class. I don't know where and when it should be initialized.

Here it is

class MyReport extends \koolreport\KoolReport
{
    use \koolreport\yii2\Friendship;

    // By adding above statement, you have claim the friendship between two frameworks
    // As a result, this report will be able to accessed all databases of Yii2
    // There are no need to define the settings() function anymore
    // while you can do so if you have other datasources rather than those
    // defined in Laravel.

    function setup()
    {
        $idLista = \Yii::$app->user->identity->contesto;

        $this->src("default")
            ->query("SELECT DATA_ORA_PRESENTAZIONE
                        FROM DOMANDE D,
                            LISTE_SCAGLIONI SCA,
                            LISTE L
                        WHERE D.ID_SCAGLIONE = SCA.ID
                        AND SCA.ID_LISTA = L.ID
                        AND FLG_ANNULLATA = 1
                        AND L.ID = $idLista")
            ->pipe(new DateTimeFormat([
                "DATA_ORA_PRESENTAZIONE" => [
                    "from" => "d/m/Y H:i:s",
                    "to"   => "F j, Y",
                ],
            ]))
            ->pipe(new Group([
                "by"    => [
                    "DATA_ORA_PRESENTAZIONE",
                ],
                "count" => "TOTALE_PER_GIORNO",
            ]))
            ->pipe(new AccumulativeColumn([
                'TOTALE_DOMANDE' => 'TOTALE_PER_GIORNO',
            ]))
            ->pipe(new ColumnRename([
                "DATA_ORA_PRESENTAZIONE" => "Giorno",
                "TOTALE_PER_GIORNO"      => "Numero di domande",
            ]))
            ->pipe($this->dataStore("domande_presentate_pergiorno"));

        $this->src("default")
            ->query("SELECT DATA_APERTURA
                        FROM DOMANDE D,
                            LISTE_SCAGLIONI SCA,
                            LISTE L
                        WHERE D.ID_SCAGLIONE = SCA.ID
                        AND SCA.ID_LISTA = L.ID
                        AND FLG_ANNULLATA = 1
                        AND L.ID = $idLista")
            ->pipe(new DateTimeFormat([
                "DATA_APERTURA" => [
                    "from" => "d/m/Y H:i:s",
                    "to"   => "F j, Y",
                ],
            ]))
            ->pipe(new Group([
                "by"    => [
                    "DATA_APERTURA",
                ],
                "count" => "TOTALE_PER_SCAGLIONE",
            ]))
            ->pipe(new AccumulativeColumn([
                'TOTALE_DOMANDE' => 'TOTALE_PER_SCAGLIONE',
            ]))
            ->pipe(new ColumnRename([
                "DATA_APERTURA"        => "Inizio scaglione",
                "TOTALE_PER_SCAGLIONE" => "Numero di domande",
            ]))
            ->pipe($this->dataStore("domande_presentate_perscaglione"));

        $this->src("default")
            ->query("SELECT max(DATA_ORA_PRESENTAZIONE) DATA_ORA_PRESENTAZIONE
                        FROM DOMANDE D,
                            LISTE_SCAGLIONI SCA,
                            LISTE L,
                            V_IMMATRICOLATI_ANNO_CORR IMM
                        WHERE D.ID_SCAGLIONE = SCA.ID
                        AND SCA.ID_LISTA = L.ID
                        AND D.COD_FISC = IMM.COD_FISC
                        AND L.CDS_COD = IMM.CDS_COD
                        AND L.ID = $idLista
                        GROUP BY D.COD_FISC")
            ->pipe(new DateTimeFormat([
                "DATA_ORA_PRESENTAZIONE" => [
                    "from" => "d/m/Y H:i:s",
                    "to"   => "F j, Y",
                ],
            ]))
            ->pipe(new Group([
                "by"    => [
                    "DATA_ORA_PRESENTAZIONE",
                ],
                "count" => "TOTALE_IMMATRICOLATI_PER_GIORNO",
            ]))
            ->pipe(new ColumnRename([
                "DATA_ORA_PRESENTAZIONE"          => "Giorno",
                "TOTALE_IMMATRICOLATI_PER_GIORNO" => "Numero di domande risultate immatricolate",
            ]))
            ->pipe($this->dataStore("domande_immatricolate"));

        $join = new Join( $this->dataStore("domande_presentate_pergiorno"), $this->dataStore("domande_immatricolate"), array("Giorno"=>"Giorno"));
        $join->pipe($this->dataStore('domande_presentate_con_immatricolazioni'));

        $newDatastore = $this->dataStore("domande_presentate_pergiorno")->join($this->dataStore("domande_immatricolate"), ["Giorno"=>"Giorno"]);
        $newDatastore->pipe($this->dataStore('domande_presentate_con_immatricolazioni2'));
    }
}

It works! Thank you, so in general it will be useful to save the data in a variable?

Perfect, thank you for the explanation, maybe update the documentation with this suggestion.