Výběr databáze – how&best practice

Doufal jsem, že odpoví někdo, kdo tomu rozumí, protože mě by taky zajímaly nějaké ty best practices.
Tak ti aspoň napíšu, jak to bastlím já. Založené je to na volání $databaze->query("USE $nazevDatabaze");

• Jeden db uživatel má přístup ke všem databázím.
• V mém případě se všechny databáze jmenují stejně, až na konec, který znamená rok (sezona_2012, sezona_2013…).
• V config.neon mám připojení k db definováno bez názvu databáze:

nette:
  database:
    dsn: 'mysql:host=localhost'

• V configu mám taky, jaká je aktuální sezóna – ta se zvolí jako výchozí.
• Všechny objekty, které pracují s db dědí base, která dostává můj objekt MenicDatabaze, kterému předávám šablonu pro název db („sezona_“) a aktuální sezónu („2013“).

  Takhle to mám proto, abych parametry v configu musel psát jen jednou a ostatní objekty pak dostanou MenicDatabaze přes autowiring __construct(NConnection $databaze, MenicDatabaze $menicDatabaze)

services:
  menic: MenicDatabaze(%sablonaDb%, %aktualniSezona%)
  hriste: HristeModel	# ano, v modelu přistupuji k databázi, nekamenujte mě

• MenicDatabaze dostává v konstruktoru i NConnection $databaze, které mu předává autowiring.

  V metodě zvolSezonu($rok) pak zkombinuje $this->sablonaDb a $rok a pomocí

  $this->databaze->query("USE $nazevDatabaze"); zvolí aktuální databázi.

Cítím, že to není tak úplně to pravé, ale nic lepšího mě nenapadlo.

@castamir: Buď jsem to nepochopil nebo máš chybu v

public function find($dbname, $key) {
    return $this->db->{$dbname}->find($key);
}

Jestli používáš Nette Database nebo NotORM, tak {$dbname} v tomhle kontextu není název databáze ale tabulky. Takže vlastně databázi nikde nevolíš.

Dobrý den,
děkuji za odpovědi. Výběr databáze pomocí Sql příkazu „USE“ se nabízel jako nejjednodušší řešení a aplikaci jsem již dříve upravil tímto způsobem. Bohužel mi čáru přes rozpočet udělal hosting, kdy až při pokusu to tam dostat jsem s hrůzou zjistil, že nepovolují stejného usera k více databázím (moc nechápu proč) a každá databáze musí mít vlastního jednoznačného uživatele. „Grant“ taky nepomohl, mají ho zakázaný.

No nicméně – jelikož jsem se obával, že na tuto mou prosbu nebude nikdo reagovat – přece jen to není minutová záležitost a osobně si myslím (dle již stávajících témat s touto problematikou), že je zde i obava o „poplivání“ případně zveřejněného kódu, jal jsem se to zkusit řešit úplně od píky a tak, jak na to v tuto chvíli stačí mé znalosti. Výsledkem je následující kód:

Databáze

CREATE DATABASE `prvni`;
CREATE DATABASE `druha`;
CREATE DATABASE `treti`;
USE `prvni`;
CREATE TABLE `pokus` (
  `PokusId` int(11) NOT NULL AUTO_INCREMENT,
  `PokusText` varchar(50) COLLATE utf8_czech_ci NOT NULL,
  PRIMARY KEY (`PokusId`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_czech_ci;

INSERT INTO `pokus` (`PokusId`, `PokusText`) VALUES
(1,	'Databaze Prvni'),
(2,	'Databaze Prvni podruhe');

USE `druha`;
CREATE TABLE `pokus` (
  `PokusId` int(11) NOT NULL AUTO_INCREMENT,
  `PokusText` varchar(50) COLLATE utf8_czech_ci NOT NULL,
  PRIMARY KEY (`PokusId`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_czech_ci;

INSERT INTO `pokus` (`PokusId`, `PokusText`) VALUES
(1,	'Databaze Druha'),
(2,	'Databaze Druha podruhe');

USE `treti`;
CREATE TABLE `pokus` (
  `PokusId` int(11) NOT NULL AUTO_INCREMENT,
  `PokusText` varchar(50) COLLATE utf8_czech_ci NOT NULL,
  PRIMARY KEY (`PokusId`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_czech_ci;

INSERT INTO `pokus` (`PokusId`, `PokusText`) VALUES
(1,	'Databaze Treti'),
(2,	'Databaze Treti podruhe');

CONFIG.NEON

#
common:
    parameters:
        dbprofiles:
            0:
                name: 'prvni'
                dsn: 'mysql:host=localhost;dbname=prvni'
                user: root
                password: root

            1:
                name: 'duha'
                dsn: 'mysql:host=localhost;dbname=druha'
                user: root
                password: root

            2:
                name: 'treti'
                dsn: 'mysql:host=localhost;dbname=treti'
                user: root
                password: root

    php:
        date.timezone: Europe/Prague
        # zlib.output_compression: yes

    nette:
        application:
            errorPresenter: Error

        database:
            dsn: 'mysql:host=localhost;dbname=prvni'
            user: root
            password: root

        session:
            expiration: 14 days

    services:
        authenticator: Authenticator
        routerFactory: RouterFactory
        router: @routerFactory::createRouter

        pokusRepository: Sandbox\PokusRepository

    factories:

production < common:

development < common:

PokusRepository

<?php
namespace Sandbox;
use Nette;
// ------------------------------------------------------------------
/**
 * Tabulka Pokus
 */
class PokusRepository extends Repository
{
    // ------------------------------------------------------------------
    /**
    * Vrat data z tabulky Pokus
    */
    public function getPokus() {
        return $this->findAll();
    }// end function
}//end class
?>

BasePresenter (Jen z důvodu vyzkoušení, zda s tím není problém)

<?php
/**
 * Base presenter for all application presenters.
 */
abstract class BasePresenter extends Nette\Application\UI\Presenter
{
    // ------------------------------------------------------------------
    /**
    * pristup k modelu
    */
    public $pokusRepository;

    // ------------------------------------------------------------------
    /**
    * Startup
    */
    protected function startup()
    {
      parent::startup();
    }//end function

    // ------------------------------------------------------------------
    /**
    * Inject model
    */
    public function injectPokusRepository(Sandbox\PokusRepository $PokusRepository)
    {
        $this->pokusRepository = $PokusRepository;
    }//end function

}//end class
?>

No a to hlavní – HomePagePresenter

<?php
use Nette\Application\UI;
use Nette\Application\UI\Form;

// ------------------------------------------------------------------
/**
 * Homepage presenter.
 */
class HomepagePresenter extends BasePresenter
{
    /** @var \Nette\Database\Connection */
    private $database;

    // ------------------------------------------------------------------
    /**
    * konstruktor
    */
      public function __construct(Nette\Database\Connection $database)
    {
        $this->database = $database;
    }//end method

    // ------------------------------------------------------------------
    /**
    * Startup
    */
    protected function startup()
    {
      //Nastaveni databaze
      $this->setDatabase();
      parent::startup();
    }//end function

    // ------------------------------------------------------------------
    /**
    * Vytvoreni formulare
    */
    protected function createComponentDbSelectForm()
    {
        $form = new UI\Form;
        $form->addSelect('Databaze', 'Databaze:')
             ->setItems($this->getDatabases());
        $form->addSubmit('send', 'Potvrdit');
        $form->onSuccess[] = $this->dbSelectFormSucceeded;
        return $form;
    }//end function

    // ------------------------------------------------------------------
    /**
    * Uspech
    */
    private function dbSelectFormSucceeded($form) {
        $values = $form->getValues();
        //Ulozeni indexu vybrane DB do session
        $session = $this->getSession("SelectedDb");
        $session->setExpiration(0);
        $session->dbIndex = $values->Databaze;
        //redirect
        $this->redirect("HomePage:Default");
    }// end function

    // ------------------------------------------------------------------
    /**
    * Seznam databazi
    */
    private function getDatabases() {
        $res = array();
        $profiles = $this->context->parameters['dbprofiles'];
        foreach($profiles as $profile){
            array_push($res,$profile["name"]);
        }//end foreach
        return $res;
    }// end function


    // ------------------------------------------------------------------
    /**
    * Nastaveni databaze ze session
    */
    private function setDatabase() {
        //Vytahnu si ze session index vybrane databaze
        $session = $this->getSession("SelectedDb");
        $dbIndex = $session->dbIndex;
        //Pokud nebylo jeste nastaveno, bude pouzita vychozi databaze
        if($dbIndex != null){
            //vytahnu info o pripojeni z config.neon
            $profile =  $this->context->parameters['dbprofiles'][$dbIndex];
            $this->database->__construct($profile["dsn"], $profile["user"], $profile["password"]);
        }//end if
    }// end function

    // ------------------------------------------------------------------
    /**
    * Render stranky
    */
	public function renderDefault()
	{
		$this->template->pokus = $this->pokusRepository->getPokus();
	}//end function
}//end class
?>

+ default.latte

{block content}
<h1>Vyber databázi:</h1>

{form dbSelectForm}
    {input Databaze}
    {input send}
{/form}

<h2>Selekt z tabulky patřičné databáze:</h2>
{foreach $pokus as $p}
    <p>{$p->PokusText}</p>
{/foreach}
{/block}

Tímto způsobem to vypadá funkčně, spíš je otázka, jakých nepřístojností jsem se dopustil vůči Nette etice…

Editoval premek_k (1. 3. 2013 13:09)

@castamir: Souhlas. Ohledně tvého předchozího příspěvku: hlavně ti tam chybí, jak bys v tom __get() měnil tu databázi :-) Jestli přes $db->query("USE $nazevDatabaze"); nebo jinak.

@premek_k: Tvoje setDatabase() je vlastně továrna na NConnection (já používám verzi bez prefixů). Mimochodem, nevolal bych __construct() ale new NConnection(), ale čti dál.
Přijde mi víc Nette definovat to v configu:

services:
	database:
		class: Nette\Database\Connection
		create: MojeDbTovarna::vytvorPripojeni
		arguments: [%dbprofiles%]

vytvorPripojeni pak bude vlastně tvoje setDatabase(). Session tam dostaneš přes auto-wiring (doufám) a definované databáze přes parametry (psáno z hlavy):

class MojeDbTovarna {
  public function vytvorPripojeni($dbprofiles, NSession $session) {
    $mojeSession = $session->getSection("SelectedDb");
    // jestli nemáš důvod používat zvláštní namespace, tak nemusíš
    $dbIndex = $mojeSession->dbIndex;
    //Pokud nebylo jeste nastaveno, bude pouzita vychozi databaze
    if ($dbIndex === null) {
      return null;
    }

    //vytahnu info o pripojeni z config.neon
    $profile =  $dbprofiles[$dbIndex];

    // tohle jsem vykradl z mého zkompilovaného configu z `createServiceNette__database__default()`
    $service = new NConnection($profile["dsn"], $profile["user"],$profile["password"], NULL);
    $service->setCacheStorage($this->getService('cacheStorage'));
    NDebugger::$blueScreen->addPanel('NDatabasePanel::renderException');
    $service->setDatabaseReflection(new NDiscoveredReflection($this->getService('cacheStorage')));
    $service->onQuery[] = array(
      $this->getService('nette.database.defaultConnectionPanel'),
      'logQuery'
    );
    return $service;
  }
}

Editoval petr.pavel (1. 3. 2013 14:40)

Díky ti za připomínky @castamir, chvíli mi bude trvat, než to pochopím, nicméně narychlo:

• duplicitni definice pripojeni k databazi (v parameters a pak nette.database)

S tímto bych se i smířil. v nette.database je nastavena výchozí databáze, samotný výčet pak v parameters. To že je ta výchozí uvedena v obou sekcích by se dalo ještě ošetřit, ale nepříjde mi to jako zásadní problém.

• PokusRepository vytvaris jako sluzbu s pripojenim k databazi „prvni“, takze bez ohledu na to, o co se snazis v setDatabase, porad budes pristupovat k databazi „prvni“. A co vic, pokud bys nedejboze zmenil tu databazi z presenteru v PokusRepository, nesmis zapomenou na to, ze se jedna o sluzbu, takze se zmeny promitnou vsude, kde to budes dal pouzivat

No nevím. na uvedeném kódu je to funkční – tzn. po výběru databáze se udělá selekt do té správné a vrátí to správná data. Je mi jasné, že to není košér, ale minimálně to funguje.

• v HomepagePresenteru injektujes databazi, ale pak znasilnujes jeji konstruktor v setDatabase (rozumnej, volas jiz podruhe stejny konstruktor, ktery jiz byl volan, jen s jinymi parametry)

Njn, to je proto, že se (krom dalších věcí) neumím vyrovnat s problémem, kdy ve __construct metodě se ještě nedostanu k session a tudíž nemám jak získat index vybrané db (což jsem původně zamýšlel takto udělat). K session se dostanu až ve startup, proto takhle „přes hlavu“.

• pouzivas context, ktery je prinejmensim nedoporucovany

Ano, o tom vím, ale opět – v tuto chvíli se mu neumím ve všech případech vyhnout ($this->context->parameters[‚dbprofiles‘];)

• mas vrstvu pro praci s databazi (jednim jeho prvkem je PokusRepository), ale presto si hrajes s databazi jako takovou v presenteru – chyba navrhu

Moc nerozumím této výtce – o několik řádků výš jsi napsal „…nedejbože změnil tu databázi v PokusRepository…“ a teď zas že bych měl. (???)

Edit: Takova uzitecna rada pro prehlednejsi a cistejsi kod: Pro metody plati pravidlo „One shot, one kill“, tedy metoda dela jen jedinou vec. Pro objekt plati v podstate to same – mel by se zabyvat v podstate jedinou oblasti, coz v pripade presenteru neni sprava pripojeni k db. Kod, ktery se ridi takovou pouckou se mnohem snad testuje.

Jasně, s tím souhlasím a věřím, že mnou zveřejněné řešení není správné v mnoha ohledech. Ale jsem v situaci, kdy nevím jak na to, správné řešení (které bych pochopil) jsem nikde nenašel, moc tomu vlastně ani nerozumím a tak zkouším, jak z toho ven. Království za kus funkčního, správně napsaného a jednoduchého kódu…

Editoval premek_k (1. 3. 2013 15:06)

Díky moc, @petr.pavel.
Myšlence rozumím, resp. nevím jen, zda a kde je potřeba vytvorPripojeni volat, či se již o to nemusím starat a vždy budu připojen ke správné databázi (ve vlastní režii jen nastavuji dbIndex v session)???
Facku už jsem si dal…

Editoval premek_k (1. 3. 2013 18:34)