Slick - Add slick flow functions with error handling using try.

[minjibir]

No description provided.

[pjfanning]

My preference would be not to change the 'Slick' object. Could you just create just create a 2nd 'SlickWithTryResult' or something like that?

[minjibir]

Absolutely. That's my first implementation, but later settled with this. I will change it.

[pjfanning]

with both new files, they are based on existing files and they should use the source headers from those files - so can you replace the source headers in your new files with

/*
 * Licensed to the Apache Software Foundation (ASF) under one or more
 * license agreements; and to You under the Apache License, version 2.0:
 *
 *   https://www.apache.org/licenses/LICENSE-2.0
 *
 * This file is part of the Apache Pekko project, which was derived from Akka.
 */

/*
 * Copyright (C) since 2016 Lightbend Inc. <https://www.lightbend.com>
 */

[minjibir]

@pjfanning file headers updated. Thank you for pointing that out.

[pjfanning]

the test code doesn't compile in scala 2.12

[error] /home/runner/work/pekko-connectors/pekko-connectors/slick/src/test/scala/docs/scaladsl/SlickWithTryResultSpec.scala:244:29: type mismatch;
[error]  found   : Seq[SlickWithTryResultSpec.this.User]
[error]  required: scala.collection.immutable.Iterable[?]
[error]       val inserted = Source(duplicateUser)
[error]                             ^
[error] /home/runner/work/pekko-connectors/pekko-connectors/slick/src/test/scala/docs/scaladsl/SlickWithTryResultSpec.scala:245:58: missing parameter type
[error]         .via(SlickWithTryResult.flowTryWithPassThrough { user =>
[error]                                                          ^
[error] /home/runner/work/pekko-connectors/pekko-connectors/slick/src/test/scala/docs/scaladsl/SlickWithTryResultSpec.scala:333:29: type mismatch;
[error]  found   : Seq[SlickWithTryResultSpec.this.User]
[error]  required: scala.collection.immutable.Iterable[?]
[error]       val inserted = Source(duplicateUser)
[error]                             ^
[error] /home/runner/work/pekko-connectors/pekko-connectors/slick/src/test/scala/docs/scaladsl/SlickWithTryResultSpec.scala:344:29: type mismatch;
[error]  found   : Seq[SlickWithTryResultSpec.this.User]
[error]  required: scala.collection.immutable.Iterable[?]
[error]       val inserted = Source(records)
[error]                            

[pjfanning]

I have committed some code changes but I'm not sure if they work yet.

[pjfanning]

seeing test failure in insert 40 records into a table (no parallelism) (new Slick with try support test)

[pjfanning]

thanks - lgtm