チェンジセット 4123

差分発生行の前後
無視リスト:
コミット日時:
2010/07/26 20:51:24 (2 年前)
コミッタ:
Seacolor
ログメッセージ:

FlexUnit?を4.10にアップデート
データベースとの接続が不確定だったので修正
パフォーマンスの向上

ファイル:

凡例:

変更無し
追加
削除
更新
コピー
移動

  • air/AirDao/AirDao.as3proj

    r3332 r4123  
    2323    <option benchmark="False" /> 
    2424    <option es="False" /> 
     25    <option locale="" /> 
    2526    <option loadConfig="" /> 
    2627    <option optimize="False" /> 
    …… 
    3637    <option linkReport="" /> 
    3738    <option loadExterns="" /> 
     39    <option staticLinkRSL="True" /> 
    3840    <option additional="+configname=air" /> 
     41    <option compilerConstants="" /> 
    3942    <option customSDK="" /> 
    4043  </build> 

  • air/AirDao/src/com/seacolorswind/dbi/AbstractStatementThread.as

    r2443 r4123  
    6060                { 
    6161                        error(Error, catchEerror, false); 
     62                         
     63                        // コネクションスレッドが起動されていない場合、起動して接続を確立します。 
     64                        if (!_resource.connector || !_resource.connector.connected) { 
     65                                var connector:ConnectionThread = new ConnectionThread(_resource); 
     66                                connector.start(); 
     67                                connector.join(); 
     68                        } 
     69                         
     70                        next(execute); 
    6271                } 
     72                 
     73                /** 
     74                 * クエリを実行します。 
     75                 */ 
     76                protected function execute():void { 
     77                } 
     78                 
    6379                /** 
    6480                 * エラーハンドラです。 

  • air/AirDao/src/com/seacolorswind/dbi/AirDao.as

    r3331 r4123  
    3939        import mx.logging.Log; 
    4040        import mx.logging.ILogger; 
     41        import flash.errors.IllegalOperationError; 
    4142         
    4243        /** 
    …… 
    7374                                } 
    7475                        } 
    75  
    76                         new ConnectionThread(resource).start(); 
    7776                } 
    7877                 
    …… 
    121120                public function create(entity:Object, callback:Function = null, errorHandler:Function = null):void { 
    122121                        if (entity is Array) { 
    123                                 ThreadQueue.addThread(resource, new BatchCreateThread(resource, entity as Array, callback, errorHandler)); 
     122                                throw new IllegalOperationError(); 
     123                                //ThreadQueue.addThread(resource, new BatchCreateThread(resource, entity as Array, callback, errorHandler)); 
    124124                        } else { 
    125125                                ThreadQueue.addThread(resource, new CreateThread(resource, entity, callback, errorHandler)); 

  • air/AirDao/src/com/seacolorswind/dbi/BatchCreateThread.as

    r2442 r4123  
    3737                 * @inheritDoc 
    3838                 */ 
    39                 override protected function run():void 
     39                override protected function execute():void 
    4040                { 
    41                         super.run(); 
     41                        logger.debug("execute({0})", arguments); 
    4242                         
    4343                        if (!_entity || !_entity.length) { 
    …… 
    5050                        _resource.connector.begin(); 
    5151 
    52                         next(execute); 
     52                        next(executeQuery); 
    5353                } 
    5454                /** 
    5555                 * クエリを実行します。 
    5656                 */ 
    57                 protected function execute():void { 
    58                         logger.debug("start execute()"); 
     57                protected function executeQuery():void { 
     58                        logger.debug("start executeQuery()"); 
    5959                        if (_isError) { 
    6060                                return; 
    …… 
    7272                        error(Error, errorHandler); 
    7373                         
    74                         logger.debug("end execute()"); 
     74                        logger.debug("end executeQuery()"); 
    7575                } 
    7676                /** 

  • air/AirDao/src/com/seacolorswind/dbi/CreateTableThread.as

    r3380 r4123  
    6464                 * @inheritDoc 
    6565                 */ 
    66                 override protected function run():void 
     66                override protected function execute():void 
    6767                { 
    68                         super.run(); 
    69                         // テーブルが作成済みの場合、スレッドを終了 
    70                         if (_resource.created[tableName] || (_entity.hasOwnProperty("created_on") && _entity.created_on)) { 
    71                                 return; 
    72                         } 
    73                         next(execute); 
    74                 } 
    75                 /** 
    76                  * クエリを実行します。 
    77                  */ 
    78                 protected function execute():void { 
     68                        logger.debug("execute({0})", arguments); 
     69                        error(Error, catchEerror, false); 
     70                         
    7971                        if (_isError) { 
    8072                                return; 
    …… 
    10799                        stmt.execute(); 
    108100                } 
     101                 
    109102                /** 
    110103                 * プロパティのデータ型に対応した列親和型を返します。 

  • air/AirDao/src/com/seacolorswind/dbi/CreateThread.as

    r2443 r4123  
    6565                 * @inheritDoc 
    6666                 */ 
    67                 override protected function run():void 
     67                override protected function execute():void 
    6868                { 
    69                         logger.debug("run({0})", arguments); 
    70                         super.run(); 
     69                        logger.debug("execute({0})", arguments); 
     70                        error(Error, catchEerror, false); 
    7171                         
    72                         var createTable:CreateTableThread = new CreateTableThread(_resource, _entity); 
    73                         createTable.start(); 
    74                         createTable.join(); 
     72                        // テーブルが未作成の場合、テーブルを作成 
     73                        if (!_resource.created[tableName] && (!_entity.hasOwnProperty("created_on") || !_entity.created_on)) { 
     74                                var createTable:CreateTableThread = new CreateTableThread(_resource, _entity); 
     75                                createTable.start(); 
     76                                createTable.join(); 
    7577 
    76                         next(execute); 
     78                                next(executeQuery); 
     79                        } else { 
     80                                executeQuery(); 
     81                        } 
    7782                } 
    7883                /** 
    7984                 * クエリを実行します。 
    8085                 */ 
    81                 protected function execute():void { 
    82                         logger.debug("execute({0})", arguments); 
     86                protected function executeQuery():void { 
     87                        logger.debug("executeQuery({0})", arguments); 
    8388                        if (_isError) { 
    8489                                return; 

  • air/AirDao/src/com/seacolorswind/dbi/Queue.as

    r2808 r4123  
    9595                { 
    9696                        logger.debug("run({0})", arguments); 
     97                         
    9798                        error(Error, errorHandler); 
     99                         
     100                        // コネクションスレッドが起動されていない場合、起動して接続を確立します。 
     101                        if (!_resource.connector || !_resource.connector.connected) { 
     102                                var connector:ConnectionThread = new ConnectionThread(_resource); 
     103                                connector.start(); 
     104                                connector.join(); 
     105                                 
     106                                next(beginTx); 
     107                        } else { 
     108                                beginTx(); 
     109                        } 
     110                } 
     111                 
     112                /** 
     113                 * トランザクションを開始します。 
     114                 */ 
     115                protected function beginTx():void { 
     116                        logger.debug("beginTx({0})", arguments); 
     117                         
    98118                        event(_resource.connector, SQLEvent.BEGIN, runQueue); 
    99119                        event(_resource.connector, SQLErrorEvent.ERROR, sqlErrorHandler); 
    …… 
    101121                        _resource.connector.begin(); 
    102122                } 
     123                 
    103124                /** 
    104125                 * キューを順番に実行します。 
    …… 
    106127                protected function runQueue(e:Event = null):void { 
    107128                        logger.debug("runQueue({0})", arguments); 
     129                         
    108130                        error(Error, errorHandler); 
     131                         
    109132                        if (_waitingQueues.length != 0) { 
    110133                                currentQueue = _waitingQueues.shift(); 
    …… 
    128151                 */ 
    129152                protected function destory(e:Event = null):void { 
     153                        logger.debug("destory({0})", arguments); 
     154                         
    130155                        error(Error, errorHandler); 
     156                         
    131157                        next(run); 
     158                         
    132159                        if (!_waitingQueues.length) wait(); 
    133160                } 

  • air/AirDao/src/com/seacolorswind/dbi/ReadThread.as

    r2443 r4123  
    9191                 * @inheritDoc 
    9292                 */ 
    93                 override protected function run():void 
     93                override protected function execute():void 
    9494                { 
    95                         logger.debug("run({0})", arguments); 
    96                         super.run(); 
    97                          
    98                         var createTable:CreateTableThread = new CreateTableThread(_resource, _entity); 
    99                         createTable.start(); 
    100                         createTable.join(); 
     95                        logger.debug("execute({0})", arguments); 
     96                        error(Error, catchEerror, false); 
     97                         
     98                        // テーブルが未作成の場合、テーブルを作成 
     99                        if (!_resource.created[tableName] && (!_entity.hasOwnProperty("created_on") || !_entity.created_on)) { 
     100                                var createTable:CreateTableThread = new CreateTableThread(_resource, _entity); 
     101                                createTable.start(); 
     102                                createTable.join(); 
    101103 
    102                         next(execute); 
     104                                next(executeQuery); 
     105                        } else { 
     106                                executeQuery(); 
     107                        } 
    103108                } 
    104109                /** 
    105110                 * クエリを実行します。 
    106111                 */ 
    107                 protected function execute():void { 
    108                         logger.debug("execute({0})", arguments); 
     112                protected function executeQuery():void { 
     113                        logger.debug("executeQuery({0})", arguments); 
    109114                        if (_isError) { 
    110115                                return; 

  • air/AirDao/src/com/seacolorswind/dbi/RemoveThread.as

    r2443 r4123  
    6363                 * @inheritDoc 
    6464                 */ 
    65                 override protected function run():void 
     65                override protected function execute():void 
    6666                { 
    67                         super.run(); 
     67                        logger.debug("execute({0})", arguments); 
     68                        error(Error, catchEerror, false); 
    6869                         
    69                         var createTable:CreateTableThread = new CreateTableThread(_resource, _entity); 
    70                         createTable.start(); 
    71                         createTable.join(); 
     70                        // テーブルが未作成の場合、テーブルを作成 
     71                        if (!_resource.created[tableName] && (!_entity.hasOwnProperty("created_on") || !_entity.created_on)) { 
     72                                var createTable:CreateTableThread = new CreateTableThread(_resource, _entity); 
     73                                createTable.start(); 
     74                                createTable.join(); 
    7275 
    73                         next(execute); 
     76                                next(executeQuery); 
     77                        } else { 
     78                                executeQuery(); 
     79                        } 
    7480                } 
    7581                /** 
    7682                 * クエリを実行します。 
    7783                 */ 
    78                 protected function execute():void { 
     84                protected function executeQuery():void { 
     85                        logger.debug("executeQuery({0})", arguments); 
    7986                        if (_isError) { 
    8087                                return; 

  • air/AirDao/src/com/seacolorswind/dbi/UpdateThread.as

    r3354 r4123  
    6363                 * @inheritDoc 
    6464                 */ 
    65                 override protected function run():void 
     65                override protected function execute():void 
    6666                { 
    67                         logger.debug("run()"); 
    68                         super.run(); 
     67                        logger.debug("execute()"); 
     68                        error(Error, catchEerror, false); 
    6969                         
    70                         var createTable:CreateTableThread = new CreateTableThread(_resource, _entity); 
    71                         createTable.start(); 
    72                         createTable.join(); 
     70                        // テーブルが未作成の場合、テーブルを作成 
     71                        if (!_resource.created[tableName] && (!_entity.hasOwnProperty("created_on") || !_entity.created_on)) { 
     72                                var createTable:CreateTableThread = new CreateTableThread(_resource, _entity); 
     73                                createTable.start(); 
     74                                createTable.join(); 
    7375 
    74                         next(execute); 
     76                                next(executeQuery); 
     77                        } else { 
     78                                executeQuery(); 
     79                        } 
    7580                } 
    7681                /** 
    7782                 * クエリを実行します。 
    7883                 */ 
    79                 protected function execute():void { 
    80                         logger.debug("execute()"); 
     84                protected function executeQuery():void { 
     85                        logger.debug("executeQuery()"); 
    8186                        if (_isError) { 
    8287                                return; 

  • air/AirDao/tests/onMemory/OnMemoryConstructorTest.as

    r3381 r4123  
    3232                public function noArguments():void { 
    3333                        var handleTimerComplete:Function = function(event:TimerEvent, passThroughData:Object):void { 
    34                                 Assert.assertTrue(testTarget.connected); 
    3534                        }; 
    3635                        var handleTimeout:Function = function handleTimeout(passThroughData:Object):void { 
    …… 
    4544                public function useIntervalThreadExecutor():void { 
    4645                        var handleTimerComplete:Function = function(event:TimerEvent, passThroughData:Object):void { 
    47                                 Assert.assertTrue(testTarget.connected); 
    4846                        }; 
    4947                        var handleTimeout:Function = function handleTimeout(passThroughData:Object):void { 

  • air/AirDao/tests/onStorage/OnStorageConstructorTest.as

    r3381 r4123  
    3535                        var handleTimerComplete:Function = function(event:TimerEvent, passThroughData:Object):void { 
    3636                                Assert.assertTrue(db.exists); 
    37                                 Assert.assertTrue(testTarget.connected); 
    3837                        }; 
    3938                        timer.addEventListener( TimerEvent.TIMER_COMPLETE, Async.asyncHandler( this, handleTimerComplete, 500, null, handleTimeout ), false, 0, true ); 
    …… 
    4746                        var handleTimerComplete:Function = function(event:TimerEvent, passThroughData:Object):void { 
    4847                                Assert.assertTrue(db.exists); 
    49                                 Assert.assertTrue(testTarget.connected); 
    5048                        }; 
    5149                        timer.addEventListener( TimerEvent.TIMER_COMPLETE, Async.asyncHandler( this, handleTimerComplete, 500, null, handleTimeout ), false, 0, true ); 

  • air/AirDao/tests/onStorage/OnStorageReadTest.as

    r3417 r4123  
    472472                                assertThat(actual, everyItem(isA(IntOnly))); 
    473473                                assertThat(actual[0], hasProperties( { 
     474                                        id: greaterThan(0), 
    474475                                        max_value: equalTo(newEntity.max_value), 
    475476                                        min_value: equalTo(newEntity.min_value)