Zırvalama Tahtası symfony, debian, PHP5, SQL ve pek çok ayrıntı

sfMixer

Daha önce Symfony'e eklenen Mixing özelliğinden bahsetmediğimi fark
ettim hazır dün yeteri kadar kurcalamış ve bir proje için kullanmışken
konu ile ilgili bir şeyler "zırvalayayım" dedim.

Symfony'nin yeni versiyonlarında bulunan Mixing özelliği sayesinde
kimi durumlar için kancalar tanımlandı. Bu tanımlardan en kolay
görebileceğiniz lib/model/om/BaseXXXXPeer.php dosyası içerisinde
doInsert doUpdate doDelete gibi methodlarının içerisinde post ve pre
kancaları, Bu kancalar sayesinde istediğimiz Model için eylem öncesi
ve/veya sonrasında her hangi bir sınıfın her hangi bir methodunu
çağırabiliyoruz. Elbette kancaların nerede ve hangi durumlar için
tanımlandığına göre parametreleri değişiyor.

Dün çözmeye çalıştığım problem ise bir tabloya yapılan insert sonrası
ilişkili olduğu başka bir tablonun yeni girilen veri için
partitionlanması idi, (table partititon için Mysql yada PostgreSQL
dökümanlarına bakabilirsiniz)

Senaryo ise şöyle idi, X tablosuna insert işlemi başarı ile
gerçekleştirilmiş ise, ilişkili tablo için (Y) partition'u oluştur ve
insert rule'lar ile check constraintleri ilgili tablolara ekle eğer bu
işlemler sırasında bir sorun ile karşılaşılır ise transaction'ı geri
al ve bir exception fırlat.

İlk önce yeni lib/util altında table partititon'u oluşturmak için
kullanacağımız sınıfı ve methodu hazırlayalım,

<?php
/**
   TODO: Documentation
 */
 
 
class tablePartitions
{
 /**
  *   XXX tablosuna yapılan insert işlemi sonrası ilgili insert
edilen ilgili veri için YYY tablosuna ait
  *   partititonlar oluşturulur ve check constraintler ile insert
rule'lar ilgili tablolara geçirilir.
  *
  *  @param String $peerName methodu çağıran modelin Base Peer'ının adı
  *  @param Object $xxxStatus veri tabanına insert edilen model
  *  @param Object Connection Connection'ı taşıyan nesne
  *  @param Integer insertId Invert edilen verinin id numarası.
  *
  *  @return Boolean false Eğer işlem başarı ile gerçekleştirilir ise
return değeri false, aksi halde tüm geri dönüş değeri hata olarak ele
alınır.
  *
  */
 public function addNewYyyTablePartition($peerName, $xxxStatus, $con,
$insertId)
 {
   $con->begin();
   $statusCode = $insertId;
   $fieldNames = BaseXXXPeer::getFieldNames(BasePeer::TYPE_FIELDNAME);
   $tableFields = null;
 
   foreach($fieldNames as $fieldname)
   {
     $tableFields .= 'NEW.'.$fieldname.', ';
   }
 
   $tableFields = substr($tableFields,  0, -2);
 
   try{
     $con->executeQuery("CREATE TABLE yyy_status_$statusCode ( CHECK(
yyy_status_id = $statusCode ) ) INHERITS (yyy)");
     $con->executeQuery("CREATE OR REPLACE RULE
yyy_rule_for_status_$insertId AS ON INSERT TO yyy WHERE (
yyy_status_id = $statusCode) DO INSTEAD
                         mysql_query("INSERT INTO yyy_status_$statusCode VALUES
($tableFields) ");
     $con->commit();
   }
   catch(Exception $e)
   {
     $con->rollback();
     throw $e;
   }
 }
}

Ardından apps/appname/config içerisinde bulunan config.php dosyası
içerisine alt satırlarda bir yerlerde XXX tablosuna yapacağımız
insertlerden sonra bir method çalıştırmak istediğimizi Symfony'e
bildirelim.

 
  sfMixer::register('BaseXXXStatusPeer:doInsert:post',
array('tablePartitions', 'addNewInviteTablePartition'));

Burada hatırlanması gereken bir model için ->save(); methodunu
kullandığımızda eğer modelimiz yeni bir instance ise ilgili mode için
BaseXXXPeer içerisinde bulunan doIndert aksi halde ise aynı Peer
dosyası içerisinde bulunan doUpdate methodlarının çağrıldığıdır. (aynı
şey delete içinde geçerli)

Şimdi sıra test'e geldi,

 $xxxStatus = new xxxStatus();
 $xxxStatus->setHede('hödö');
 $xxxStatus->setHodo('hede');
 $xxxStatus->save();

Kayıt başarı ile gerçekleştirildikten sonra birim yazmış olduğumuz
tablePartitions sınıfı içerisinde bulunan addNewYyyTablePartition
isimli method çağıralacaktır. Bir uygulamaya bu kadar az müdahale ile
böylesi işlemler yaptırabilmek oldukça güzel bir şey.. Symfony ile
hayatınıza devam edin ...