Apex の一括処理の使用

1global void finish(Database.BatchableContext BC){
2   // Get the ID of the AsyncApexJob representing this batch job
3   // from Database.BatchableContext.
4   // Query the AsyncApexJob object to retrieve the current job's information.
5   AsyncApexJob a = [SELECT Id, Status, NumberOfErrors, JobItemsProcessed,
6      TotalJobItems, CreatedBy.Email
7      FROM AsyncApexJob WHERE Id =
8      :BC.getJobId()];
9   // Send an email to the Apex job's submitter notifying of job completion.
10   Messaging.SingleEmailMessage mail = new Messaging.SingleEmailMessage();
11   String[] toAddresses = new String[] {a.CreatedBy.Email};
12   mail.setToAddresses(toAddresses);
13   mail.setSubject('Apex Sharing Recalculation ' + a.Status);
14   mail.setPlainTextBody
15   ('The batch Apex job processed ' + a.TotalJobItems +
16   ' batches with '+ a.NumberOfErrors + ' failures.');
17   Messaging.sendEmail(new Messaging.SingleEmailMessage[] { mail });
18}

1global class SearchAndReplace implements Database.Batchable<sObject>{
2
3   global final String Query;
4   global final String Entity;
5   global final String Field;
6   global final String Value;
7
8   global SearchAndReplace(String q, String e, String f, String v){
9
10      Query=q; Entity=e; Field=f;Value=v;
11   }
12
13   global Database.QueryLocator start(Database.BatchableContext BC){
14      return Database.getQueryLocator(query);
15   }
16
17   global void execute(Database.BatchableContext BC, List<sObject> scope){
18     for(sobject s : scope){
19     s.put(Field,Value); 
20     }
21     update scope;
22    }
23
24   global void finish(Database.BatchableContext BC){
25   }
26}

1ID batchprocessid = Database.executeBatch(reassign);
2
3AsyncApexJob aaj = [SELECT Id, Status, JobItemsProcessed, TotalJobItems, NumberOfErrors 
4                    FROM AsyncApexJob WHERE ID =: batchprocessid ];

1Boolean isSuccess = System.FlexQueue.moveBeforeJob(jobToMoveId, jobInQueueId);

1String cronID = System.scheduleBatch(reassign, 'job example', 1);
2
3CronTrigger ct = [SELECT Id, TimesTriggered, NextFireTime
4                FROM CronTrigger WHERE Id = :cronID];
5
6// TimesTriggered should be 0 because the job hasn't started yet.
7System.assertEquals(0, ct.TimesTriggered);
8System.debug('Next fire time: ' + ct.NextFireTime); 
9// For example:
10// Next fire time: 2013-06-03 13:31:23

1global class UpdateAccountFields implements Database.Batchable<sObject>{
2   global final String Query;
3   global final String Entity;
4   global final String Field;
5   global final String Value;
6
7   global UpdateAccountFields(String q, String e, String f, String v){
8             Query=q; Entity=e; Field=f;Value=v;
9   }
10
11   global Database.QueryLocator start(Database.BatchableContext BC){
12      return Database.getQueryLocator(query);
13   }
14
15   global void execute(Database.BatchableContext BC, 
16                       List<sObject> scope){
17      for(Sobject s : scope){s.put(Field,Value); 
18      }      update scope;
19   }
20
21   global void finish(Database.BatchableContext BC){
22
23   }
24
25}

1// Query for 10 accounts
2String q = 'SELECT Industry FROM Account LIMIT 10';
3String e = 'Account';
4String f = 'Industry';
5String v = 'Consulting';
6Id batchInstanceId = Database.executeBatch(new UpdateAccountFields(q,e,f,v), 5);

1// Query for accounts that aren't in the Recycle Bin
2String q = 'SELECT Industry FROM Account WHERE isDeleted=false LIMIT 10';
3String e = 'Account';
4String f = 'Industry';
5String v = 'Consulting';
6Id batchInstanceId = Database.executeBatch(new UpdateAccountFields(q,e,f,v), 5);

1// Query for invoices that aren't in the Recycle Bin
2String q = 
3  'SELECT Description__c FROM Invoice_Statement__c WHERE isDeleted=false LIMIT 10';
4String e = 'Invoice_Statement__c';
5String f = 'Description__c';
6String v = 'Updated description';
7Id batchInstanceId = Database.executeBatch(new UpdateInvoiceFields(q,e,f,v), 5);

1global class OwnerReassignment implements Database.Batchable<sObject>{
2String query;
3String email;
4Id toUserId;
5Id fromUserId;
6
7global Database.querylocator start(Database.BatchableContext BC){
8            return Database.getQueryLocator(query);}
9
10global void execute(Database.BatchableContext BC, List<sObject> scope){
11    List<Account> accns = new List<Account>();
12
13   for(sObject s : scope){Account a = (Account)s;
14        if(a.OwnerId==fromUserId){
15            a.OwnerId=toUserId;
16            accns.add(a);
17            }
18        }
19
20update accns;
21    
22}
23global void finish(Database.BatchableContext BC){
24Messaging.SingleEmailMessage mail = new Messaging.SingleEmailMessage();
25
26mail.setToAddresses(new String[] {email});
27mail.setReplyTo('batch@acme.com');
28mail.setSenderDisplayName('Batch Processing');
29mail.setSubject('Batch Process Completed');
30mail.setPlainTextBody('Batch Process has completed');
31
32Messaging.sendEmail(new Messaging.SingleEmailMessage[] { mail });
33}
34}

1OwnerReassignment reassign = new OwnerReassignment();
2reassign.query = 'SELECT Id, Name, Ownerid FROM Account ' + 
3                'WHERE ownerid=\'' + u.id + '\'';
4reassign.email='admin@acme.com';
5reassign.fromUserId = u;
6reassign.toUserId = u2;
7ID batchprocessid = Database.executeBatch(reassign);

1global class BatchDelete implements Database.Batchable<sObject> {
2   public String query;
3
4   global Database.QueryLocator start(Database.BatchableContext BC){
5      return Database.getQueryLocator(query);
6   }
7
8   global void execute(Database.BatchableContext BC, List<sObject> scope){
9      delete scope;
10      DataBase.emptyRecycleBin(scope);
11   }
12
13   global void finish(Database.BatchableContext BC){
14   }
15}

1BatchDelete BDel = new BatchDelete();
2Datetime d = Datetime.now();
3d = d.addDays(-1);
4// Replace this value with the folder ID that contains
5// the documents to delete.
6String folderId = '00lD000000116lD';
7// Query for selecting the documents to delete
8BDel.query = 'SELECT Id FROM Document WHERE FolderId=\'' + folderId + 
9    '\' AND CreatedDate < '+d.format('yyyy-MM-dd')+'T'+
10    d.format('HH:mm')+':00.000Z';
11// Invoke the batch job.
12ID batchprocessid = Database.executeBatch(BDel);
13System.debug('Returned batch process ID: ' + batchProcessId);

1global class SearchAndReplace implements Database.Batchable<sObject>, 
2   Database.AllowsCallouts{
3}

1global class SummarizeAccountTotal implements 
2    Database.Batchable<sObject>, Database.Stateful{
3
4   global final String Query;
5   global integer Summary;
6  
7   global SummarizeAccountTotal(String q){Query=q;
8     Summary = 0;
9   }
10
11   global Database.QueryLocator start(Database.BatchableContext BC){
12      return Database.getQueryLocator(query);
13   }
14   
15   global void execute(
16                Database.BatchableContext BC, 
17                List<sObject> scope){
18      for(sObject s : scope){
19         Summary = Integer.valueOf(s.get('total__c'))+Summary;
20      }
21   }
22
23global void finish(Database.BatchableContext BC){
24   }
25}

1// Implement the interface using a list of Account sObjects
2// Note that the initialState variable is declared as final
3
4global class MyBatchable implements Database.Batchable<sObject> {
5  private final String initialState;
6  String query;
7  
8  global MyBatchable(String intialState) {
9    this.initialState = initialState;
10  }
11
12  global Database.QueryLocator start(Database.BatchableContext BC) {
13    // Access initialState here 
14    
15    return Database.getQueryLocator(query);
16  }
17
18  global void execute(Database.BatchableContext BC, 
19                      List<sObject> batch) {
20    // Access initialState here 
21    
22  }
23
24  global void finish(Database.BatchableContext BC) {
25    // Access initialState here 
26    
27  }
28}

1public static testMethod void testBatch() {
2   user u = [SELECT ID, UserName FROM User 
3             WHERE username='testuser1@acme.com'];
4   user u2 = [SELECT ID, UserName FROM User 
5              WHERE username='testuser2@acme.com'];
6   String u2id = u2.id;
7// Create 200 test accounts - this simulates one execute.  
8// Important - the Salesforce.com test framework only allows you to 
9// test one execute.  
10
11   List <Account> accns = new List<Account>();
12      for(integer i = 0; i<200; i++){
13         Account a = new Account(Name='testAccount'+'i', 
14                     Ownerid = u.ID); 
15         accns.add(a);
16      }
17   
18   insert accns;
19   
20   Test.StartTest();
21   OwnerReassignment reassign = new OwnerReassignment();
22   reassign.query='SELECT ID, Name, Ownerid ' +
23            'FROM Account ' +
24            'WHERE OwnerId=\'' + u.Id + '\'' +
25            ' LIMIT 200';
26   reassign.email='admin@acme.com';
27   reassign.fromUserId = u.Id;
28   reassign.toUserId = u2.Id;
29   ID batchprocessid = Database.executeBatch(reassign);
30   Test.StopTest();
31
32   System.AssertEquals(
33           database.countquery('SELECT COUNT()'
34              +' FROM Account WHERE OwnerId=\'' + u2.Id + '\''),
35           200);  
36   
37   }
38}