Skip to content

Instantly share code, notes, and snippets.

@PavelPenkov
Created July 23, 2020 14:08
Show Gist options
  • Save PavelPenkov/99cb94d4b674afca626640aecbe3c50e to your computer and use it in GitHub Desktop.
Save PavelPenkov/99cb94d4b674afca626640aecbe3c50e to your computer and use it in GitHub Desktop.
package example
import java.sql.DriverManager
import java.util
import com.microsoft.sqlserver.jdbc.{ISQLServerBulkData, SQLServerBulkCopy}
import scala.jdk.CollectionConverters._
class ReproData extends ISQLServerBulkData {
override def getColumnOrdinals: util.Set[Integer] = (1 to 10).map(_.asInstanceOf[Integer]).toSet.asJava
override def getColumnName(column: Int): String = s"col_$column"
override def getColumnType(column: Int): Int = java.sql.Types.INTEGER
override def getPrecision(column: Int): Int = 0
override def getScale(column: Int): Int = 4
override def getRowData: Array[AnyRef] = ???
override def next(): Boolean = ???
}
object Repro extends App {
val conn = DriverManager.getConnection("jdbc:sqlserver://localhost:1433", "sa", "yourStrong(!)Password")
val copy = new SQLServerBulkCopy(conn)
copy.setDestinationTableName("my_table")
copy.writeToServer(new ReproData)
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment