|
2 | 2 |
|
3 | 3 | import io.dapr.client.DaprClient; |
4 | 4 | import io.dapr.client.domain.HttpExtension; |
| 5 | +import io.dapr.it.spring.data.TestDaprSpringDataConfiguration; |
5 | 6 | import io.dapr.testcontainers.Component; |
6 | 7 | import io.dapr.testcontainers.DaprContainer; |
7 | 8 | import io.dapr.testcontainers.DaprLogLevel; |
|
14 | 15 | import org.springframework.beans.factory.annotation.Autowired; |
15 | 16 | import org.springframework.boot.test.context.SpringBootTest; |
16 | 17 | import org.springframework.boot.testcontainers.service.connection.ServiceConnection; |
| 18 | +import org.springframework.test.context.ContextConfiguration; |
17 | 19 | import org.springframework.test.context.junit.jupiter.SpringExtension; |
18 | 20 | import org.testcontainers.containers.Network; |
19 | 21 | import org.testcontainers.containers.PostgreSQLContainer; |
|
24 | 26 | import java.util.Arrays; |
25 | 27 | import java.util.Collections; |
26 | 28 | import java.util.HashMap; |
| 29 | +import java.util.List; |
27 | 30 | import java.util.Map; |
28 | 31 |
|
29 | 32 | import static io.dapr.it.spring.data.DaprSpringDataConstants.STATE_STORE_NAME; |
@@ -96,7 +99,15 @@ public void beforeEach() { |
96 | 99 |
|
97 | 100 | @Test |
98 | 101 | public void invokeBindingTest() { |
| 102 | + postgreBindingClient.exec("CREATE TABLE \"demodata\" (\n" + |
| 103 | + "\t\"id\" serial NOT NULL UNIQUE,\n" + |
| 104 | + "\t\"name\" varchar(255) NOT NULL,\n" + |
| 105 | + "\tPRIMARY KEY(\"id\")\n" + |
| 106 | + ");", List.of()); |
99 | 107 |
|
| 108 | + postgreBindingClient.exec("INSERT INTO demodata (id, name) VALUES ($1, $2)", "[1, \"hello\"]"); |
| 109 | + |
| 110 | + assertEquals("[[1,\"hello\"]]", postgreBindingClient.query("SELECT * FROM demodata", List.of())); |
100 | 111 | } |
101 | 112 |
|
102 | 113 | @Test |
|
0 commit comments