public class Address : BizEntityBase
{
    [MaxLength(35), Required] public string      Address1;
    [MaxLength(35)          ] public string      Address2;
    [MaxLength(35), Required] public string      City;
    [MaxLength(35), Required] public string      Region;
    [               Required] public string      PostalCode;
    [               Required] public CountryCode CountryCode;

    public override void Validate()
    {
        // 1-й уроовень.
        //
        base.Validate();

        // 2-й.
        //
        switch (CountryCode)
        {
            case CountryCode.US:
                if (PostalCode.Length != 5 || PostalCode.Length != 9)
                    throw new Exception("Zip must be 5 or 9 digits.");
                break;

            case CountryCode.RU:
                if (PostalCode.Length != 6)
                    throw new Exception("Почтовый индекс должен содержать 6 цифр.");
                break;
        }
    }
}

public class AddressService : ServiceBase
{
    public void AddAddress(Address address)
    {
        // 1-й, 2-й.
        //
        address.Validate();

        // 3-й. Вызываем код проверки адреса на существование.
        // Используем софт компании Address Validation, Inc.
        //
        new Agents.AddressValidator().Validate(address);

        // Сохраняем обхект в БД.
        //
        new AddressDataAccessor().AddAddress(address);
    }
}

IF EXISTS (SELECT * FROM sysobjects WHERE type = 'U' AND name = 'Address')
BEGIN
    PRINT 'Dropping Table Address'
    DROP   Table    Address
END
GO

PRINT 'Creating Table Address'
GO

CREATE TABLE dbo.Address
(
    AddressID  int IDENTITY (1,1) NOT NULL CONSTRAINT PK_Address PRIMARY KEY CLUSTERED,
    Address1       nvarchar(35)   NOT NULL,
    Address2       nvarchar(35),
    City           nvarchar(35)   NOT NULL,
    Region         nvarchar(35)   NOT NULL,
    PostalCode     nvarchar(11)   NOT NULL,
    CountryCode    udt_CountryCode
) ON [PRIMARY]

GRANT SELECT ON Customer TO PUBLIC
GO

select FucObjects

select FucObjects typeing typeas(FucObjects, FucDocument, FucMessage)

select a, b where a=10 and b=20

— Должен быть сервер приложений на котором клиенты открывают сессии. Для каждой сессии есть экземпляр VM доменного языка, т.е. состояние программ, например, значения глобальных переменных, держится на протяжении всей сессии. Хочу отметить, что это вовсе не означает, что доменные объекты, будучи один раз загружены в память, больше до окончания сессии не выгружаются и их состояние не синхронизируется с базой, я этого нигде и раньше не говорил.
— Работа бизнес логики в течении сессии осуществляется посредством транзакций. То есть я сейчас ввожу понятие "framework-транзакции" (назовем ее так). Требования к уровню изоляции этой транзакции — такие же, как и для "Oracle-сериализованной", см. здесь
Автор: stalcer
Дата: 25.03.05
.
— В сессии на текущий момент может быть не более одной "framework-транзакции".
— Система должна обеспечивать навигационный доступ и механизм запросов.
— Система должна обеспечивать согласованность данных (состояний доменных объектов), видимых бизнес логике (прикладной программе), строго в соответсвии с требованиями уровня изоляции для "framework-транзакции".

— Мне все равно как это называется statefull или stateless, скорее нечто среднее.
— Я нигде не упоминал ни про какие кэши, так как они являются лишь средством оптимизации и ни в коем случае не должны менять логику работы.
— Однако уровень изоляции был выбран именно такой, для простоты реализации кэшей. При другом уровне изоляции, например, read committed, реализация была бы более сложной и производительность могла бы оказаться практически неприемлимой.
— Но, такой уровень изоляции имхо удобен и для прикладных программистов.
— Так как в сессии на текущий момент может быть не более одной "framework-транзакции", то IdentityMap — одна на сессию!

GZ>Не ширее а ширше. Диревня.

persistent class A 
{
    public persistent int  X; required;  // В специальном языке 'int' может содержать значение 
                                         // undefined, что примерно тоже, что и NULL в SQL,
                                         // и совсем не тоже, что C# null.
    public persistent byte Y;

    constraint (Y) // Перечень полей, по изменению которых делать проверку.
    { 
        if (y < 0)
            throw new ConstraintException("бла-бла-бла файлед, нафиг!");
    }
    
    constraint (X, Y)
    {
        if (x > y)
            throw new ConstraintException("бла-бла-бла 2 файлед, блин!");
    }
}

void P(A a)
{
    a.X = 7;
    a.Y = 5;   // Ошибка. Второй констрейнт.
    a.Y = -2;  // Ошибка. Первый констрейнт.
    
    deffer (a)   // 'deffer' - ключевое слово. Проверки откладываются до конца блока.
    {
        a.X = 19;  // Нет ошибки. Проверка отложена.
        a.Y = 20;
    };
}

public bool Predicate1(object o)
{
    return o is ClassA;
}
public bool Predicate2(object o)
{
    return o is Interface1 && o is Interface2;
}

GZ>SELECT A WHERE A.f>20 and A.B.f>10 AND A.B.C.f>20
GZ>

GZ>SELECT A WHERE (A.B.F>20 AND A.C.F>20 AND A.C.F1=A.B.F1)
GZ>

GZ>SELECT A.* FROM A 
GZ>WHERE 
GZ>    A.B IN (SELECT B.OID FROM WHERE B>20 AND 
GZ>        B.F1 IN (SELECT C.F1 FROM C WHERE C.F>20))
GZ>

GZ>SELECT A.* FROM A 
GZ>WHERE 
GZ>    A.С IN (SELECT C.OID FROM C WHERE C.F>20 AND 
GZ>        с.F1 IN (SELECT B.F1 FROM WHERE B>20 ))
GZ>

GZ>Стандартные БД не умеют развертывать такие запросы. А без информации о кардинальности, можно сделать очень неприлично долгий запрос.

select * from A 
inner join B on A.B = B.OID 
inner join C on A.C = C.OID
where C.F1 = B.F1
and B.F > 20 and C.F > 20

        protected virtual string Category_IsValidate()
        {
            string strResult = "";
            if (textboxCategory.Text == "")
            {
                strResult = "Поле не может быть пустым!";
                return strResult;
            }
            return strResult;
        }
        private void textboxCategory_Validating(object sender, CancelEventArgs e)
        {
            string rez = Category_IsValidate();
            if (rez != "")
            {
                this.objErrorProvider.SetError(textboxCategory, rez);
            }
            else
            {
                this.objErrorProvider.SetError(textboxCategory, "");
            }
        }

— наличием конструктора с определенной сигнатурой, например, конструктора без параметров, чтобы форма (или другой сервис) могла без проблем создавать новые объекты
— полями (без сеттеров), чтобы форма могла присваивать значения в любой последовательности
— и функцией validate, которая вызывается формой или другими сервисами автоматически.

— с такими конструкторами, какие необходимы логически
— со свойствами
— и т.д.

— валидация самого объекта
— валидация состояния системы по завершению бизнес транзакции

    obj.Delete();
    // Some actions...
    Transaction.Commit();

S>>Кстати любимую здесь всеми проблему низкой производительности при навигационном доступе к объектам по моему можно относительно просто решить .

— Такая подсистема, как часть сервера приложений не должна быть сильно надежной и масштабируемой.
— Она предназначена для единственной цели — навигационный доступ, т.е. она не будет содержать, например, подсистемы выполнения запросов, и т.п.

— Он один на весь сервер приложений, а не на сессию.
— Он большой . Я пока рассматриваю только оперативную память, так как для большого круга задач этого (500Мб — 1Гб) будет вполне достаточно. Но можно и о работе с файлом подумать.
— Он умеет сериализоваться в файл при выключении сервера приложений и считываться при включении. Возможно ассинхронно, но 500Мб — не так уж и долго (проверял). Большое количество данных, достаточно статично, и вообще не будет перечитываться из базы.
— Он транзакционный. Т.е. хранит объекты в индексе, ключом которого является сочетание (OID, Version). При изменении объекта его новое состояние сбрасывается не только в базу, но и в этот кэш. Т.е. другим сессиям не нужно будет перечитывать объект из базы. Это один из важных моментов.

GZ>Ну не пойму. Сериализованные транзакции без блокировки невозможны. Притом блокировки на чтение. Притом блокировки должны быть упорядочены. Может ты ошибся с сериализованными транзакциями?

Т.е. Oracle-сериализованная транзакция на протяжении всей своей жизни видит все данные в виде как они были на момент ее начала.

create table ST (
  x number,
    y number
)
/
insert into ST values (1, 2)
/
insert into ST values (3, 4)
/
commit

set transaction isolation level SERIALIZABLE
/
select * from ST /* Типа прочитали данные в сериализованной транзакции,
                    по твоему они должны были заблокироваться! */

update ST set y = 10 /* Думаешь здесь будет ошибка или соединение повиснет, 
                        фигушки, все сработает! */
/
commit /* И это сработает */

select * from ST /* Читаем еще раз в той же транзакции, т.к. соединение1 ни 
                    коммита ни роллбака не делало.
                    И получаем следующий набор данных:
                    *X*   *Y*
                     1     2
                     3     4
                    т.е. не видим подтвержденных соединением2 данных,
                    т.е. транзакция на самом деле сериализованная. */
/
commit /* Ну и это не вызовет никаких ошибок. */

Because Oracle does not use read locks in either read-consistent or serializable
transactions, data read by one transaction can be overwritten by another...

create table ST (
  x number,
    y number
)
/
insert into ST values (1, 2)
/
insert into ST values (3, 4)
/
commit

set transaction isolation level SERIALIZABLE /* Начинаем транзакцию до update'а во втором соединении.
                                                Это важно. */

set transaction isolation level SERIALIZABLE
/
update ST set y = y + 1 /* Пройдет нормально */

update ST set y = y + 1 /* Повесится до окончания транзакции в Соединении2 */

commit /* Пройдет нормально */

ORA-08177 can't serialize access for this transaction
Cause: Encountered data changed by an operation that occurred after the start
of this serializable transaction.
Action: In read/write transactions, retry the intended operation or transaction.

create table ST (
  x number,
    y number
)
/
insert into ST values (1, 2)
/
insert into ST values (3, 4)
/
commit

set transaction isolation level SERIALIZABLE
/
select y from ST where x=1;

update st set y=3 where x=3;

set transaction isolation level SERIALIZABLE
/
select y from ST where x=3;

update st set y=3 where x=1;

commit;

commit;

  // Пусть obj.Name изначально равно "aaa"
    obj.Name = "bbb";
    cursor = #oql select x from SomeObjects x where x.Name = "aaa";

GZ>Если говорить по твоим словам — объекты между системными транзакциями перегружаются Я начал тормозить.

S>>  // Пусть obj.Name изначально равно "aaa"
S>>    obj.Name = "bbb";
S>>    cursor = #oql select x from SomeObjects x where x.Name = "aaa";
S>>

NamedLocks.Lock("Табеля", LockKind.Shared);
// Здесь работаем с табелями...
Commit; // Блокировка снялась.

class SellingItem 
{
    public Ware SellingWare;  // Ссылка на товар.
    public int  Amount;       // Продаваемое количество.
};

obj.Name = "bbb";

cursor = #oql select x from SomeObjects x where x.Name = "aaa";

А решается данная проблема просто, при загрузке результатов сначало загружаешь OID объекта, если таковой в кэше присутсвует то делаешь MoveNext, а наверх выдаешь ссылку на кешируемый объект(если надо).

obj = GetById(5);
obj.Name = "zzz";

cursor = #oql select x from SomeObjects x where x.Name = "aaa";

foreach (cursor)
{
  System.WriteLn(cursor.OID + "  " + cursor.Name);
};

obj = GetById(5);
obj.Name = "zzz";

cursor = #oql select x from SomeObjects x where x.Name = "aaa";

6.2: И тогда получается, что эти несколько системных транзакций — короткие (какие и должны быть SQL транзакции) и без интерактива с пользователем. При таком подходе для точной реализации задачи из пункта 5 (важны 5.1, 5.2 и 5.3) нам нужно всего лишь два механизма:
6.2.1: Оптимистические snapshot системные транзакции.
6.2.2: Механизм "блокировок уровня бизнес транзакций". См. 5.6.

enum LockMode
{
    Shared,
    Noshare
};

interface LockService
{
    void LockObject(long objID, LockMode lockMode, long businessTransactionId);
    void LockObjects(long[] objIDs, LockMode[] lockModes, long businessTransactionId);
    void RemoveAllTransactionLocks(long businessTransactionId);
};

obj.Name = "zzz";

obj.Lock(LockMode.Shared); // Заблокировали, специально, чтобы никто в течении 
                           // этой бизнес транзакции не изменил этот объект.
                           // Причем сами мы менять его не собираемся.
// Долго-долго работаем с obj.
commit;

obj.Name = "xxx";
commit;