Spring Data Unlocked: Getting Started With Java and MongoDB

1
{
2
   "id": "672182814338f60133ee26e1",
3
   "transactionType": "Debit",
4
   "amount": 888.0,
5
   "currency": "USD",
6
   "status": "In Progress",
7
   "description": "Transfer to Ricardo",
8
   "createdAt": "2024-10-09T14:00:00",
9
   "accountDetails": {
10
       "originator": {
11
           "accountNumber": "2376543213",
12
           "name": "Maria",
13
           "bank": "Bank G"
14
       },
15
       "beneficiary": {
16
           "accountNumber": "2234987651",
17
           "name": "Ricardo Mello",
18
           "bank": "Bank V"
19
       }
20
   }
21
}

1
spring.application.name=SpringShop
2
spring.data.mongodb.uri=<YOUR_CONNECTION_STRING>
3
spring.data.mongodb.database=springshop

1
package com.mongodb;
2
3
import lombok.Data;
4
import org.springframework.data.annotation.Id;
5
import org.springframework.data.mongodb.core.mapping.Document;
6
import java.time.LocalDateTime;
7
8
@Document(collection = "transactions")
9
@Data
10
public class Transaction {
11
   @Id
12
   private String id;
13
   private String transactionType;
14
   private Double amount;
15
   private String currency;
16
   private String status;
17
   private String description;
18
   private LocalDateTime createdAt;
19
   private AccountDetails accountDetails;
20
21
   public record AccountDetails(Originator originator, Beneficiary beneficiary) {}
22
   public record Originator(String accountNumber, String name, String bank) {}
23
   public record Beneficiary(String accountNumber, String name, String bank) {}
24
}

1
package com.mongodb;
2
3
import org.springframework.data.mongodb.repository.MongoRepository;
4
import org.springframework.stereotype.Repository;
5
6
@Repository
7
public interface TransactionRepository extends MongoRepository <Transaction, String>{} 

1
package com.mongodb;
2
import org.springframework.stereotype.Service;
3
import java.util.List;
4
5
@Service
6
public class TransactionService {
7
   private final TransactionRepository transactionRepository;
8
9
   public TransactionService(TransactionRepository transactionRepository) {
10
       this.transactionRepository = transactionRepository;
11
   }
12
   List<Transaction> getTransactions() {
13
       return transactionRepository.findAll();
14
   }
15
   public Transaction save(Transaction transaction) {
16
       return transactionRepository.save(transaction);
17
   }
18
}

1
package com.mongodb;
2
3
import org.springframework.http.HttpStatus;
4
import org.springframework.http.ResponseEntity;
5
import org.springframework.web.bind.annotation.*;
6
7
import java.util.List;
8
9
@RestController
10
@RequestMapping("/transactions")
11
public class TransactionController {
12
13
   private final TransactionService transactionService;
14
15
   public TransactionController(TransactionService transactionService, TransactionRepository transactionRepository) {
16
       this.transactionService = transactionService;
17
   }
18
19
   @GetMapping
20
   public List<Transaction> getTransactions() {
21
       return transactionService.getTransactions();
22
   }
23
24
   @PostMapping
25
   public ResponseEntity<Transaction> create(@RequestBody Transaction transaction) {
26
       return ResponseEntity.status(HttpStatus.CREATED).body(transactionService.save(transaction));
27
   }
28
}

1
 curl --location 'http://localhost:8080/transactions' \
2
--header 'Content-Type: application/json' \
3
--data '{
4
       "transactionType": "Transfer",
5
           "amount": 1500.5,
6
           "currency": "USD",
7
           "status": "Completed",
8
           "description": "Transfer to Ricardo",
9
           "createdAt": "2024-10-09T14:00:00.000Z",
10
           "accountDetails": {
11
       "originator": {
12
           "accountNumber": "9876543210",
13
                   "name": "Maria Faria",
14
                   "bank": "Bank A"
15
       },
16
       "beneficiary": {
17
           "accountNumber": "1234987654",
18
                   "name": "Ricardo Mello",
19
                   "bank": "Bank B"
20
       }
21
   }
22
   }'

1
curl --location 'http://localhost:8080/transactions'