java - 无法使用 Java SocketFactory 库连接到 Cloud SQL

Question

我正在尝试使用我的 java 代码连接到 Cloud SQL ( Mysql )。我收到以下错误 -

com.mysql.jdbc.exceptions.jdbc4.MySQLNonTransientConnectionException: Could not create socket factory 'com.google.cloud.sql.mysql.SocketFactory' due to underlying exception: 
        at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
        at org.apache.spark.deploy.SparkSubmit$.doRunMain$1(SparkSubmit.scala:185)
        at org.apache.spark.deploy.SparkSubmit$.submit(SparkSubmit.scala:210)
        at org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:124)
        at org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala)
Caused by: java.lang.ClassNotFoundException: com.google.cloud.sql.mysql.SocketFactory

这是我的代码 -

package utils
import java.sql.DriverManager
import java.sql.Connection
import scala.collection.mutable.ListBuffer
import entity.AnalyticFieldEntity
import compute.driver.AnalyticTools
import entity.ErrorHandlingEntity

object ScalaDbConnect {

    def getAnalyticBatchMap(toolId : Int, paramMap: Map[String, String]): Map[String, Int] = {
    val methodName = "getAnalyticBatchMap"
    val errorMode = paramMap.get("mode")+"("+paramMap.get("analyticSource")+")"

    val dbTuple = DbPropertiesReader.getDbProperties()


      val databaseName = dbTuple._3
      val instanceConnectionName = dbTuple._4
      val username= dbTuple._1
      val password= dbTuple._2


    var connection: Connection = null
    val analyticMap = collection.mutable.Map.empty[String, Int]
    try {
      //[START doc-example]
      val jdbcUrl = String.format(
        "jdbc:mysql://google/%s?cloudSqlInstance=%s&"
            + "socketFactory=com.google.cloud.sql.mysql.SocketFactory", databaseName, instanceConnectionName);

      println(jdbcUrl);
      //Class.forName("com.mysql.jdbc.GoogleDriver");
      val connection = DriverManager.getConnection(jdbcUrl, username, password);
      println(connection);

    //[END doc-example]

      try 
      {

        val statement = connection.createStatement()
        val resultSet = statement.executeQuery("SELECT omnitureColumnHeader.columnHeaderId, case when analyticFieldMap.isTag = 1 then concat(\"tag_\",analyticFieldMap.entityField) else  " +
        "analyticFieldMap.entityField  end as entityField FROM omnitureColumnHeader INNER JOIN analyticFieldMap ON " +
        "analyticFieldMap.analyticFieldBatch=omnitureColumnHeader.columnHeaderValue where analyticFieldMap.toolId = " + toolId);

        System.out.println("resultSet: 2" + statement);
        System.out.println("statement: 2" + resultSet);


        while (resultSet.next()) {

                    System.out.println("inside the content loop: 2");
          analyticMap += resultSet.getString("entityField") -> resultSet.getInt("columnHeaderId")


           }


        System.out.println("analyticMap: 2" + analyticMap);
    }
      catch
      {
         case _: Throwable => println("Got some other kind of exception")
      }


    } catch {
      case e: Exception =>
               val errorHandlingEntity = new ErrorHandlingEntity()
                  errorHandlingEntity.Mode=errorMode
                  errorHandlingEntity.Tool=paramMap.get("tool").toString()
                  errorHandlingEntity.Message="DB Connection Issue"
                  errorHandlingEntity.Trace=e.printStackTrace().toString()
                  errorHandlingEntity.Source = "Spark"
                  errorHandlingEntity.YarnAppId=paramMap.get("appID").toString()
                  errorHandlingEntity.MethodName=methodName
                  errorHandlingEntity.ReThrow = true
                  errorHandlingEntity.CurrentException=e

                  ErrorHandlingFramework.HandleException(errorHandlingEntity)
    }
    connection.close()

    analyticMap.toMap

  }
}

我已在 POM.XML 中添加了以下详细信息

<dependency>
    <groupId>com.google.cloud.sql</groupId>
    <artifactId>mysql-socket-factory</artifactId>
    <version>1.0.3</version>
</dependency>

这是完整的 POM.XML - https://pastebin.com/jvxSBZMX

我正在尝试使用我的 scala 代码连接到 Google Cloud SQL，并且我正在使用 JAVA API。 我面临的问题表明，我无法访问连接的正确类。

如有任何帮助，我们将不胜感激。

期待解决方案。

谢谢

Answer 1

问题在于谷歌云如何运行maven Build。

它无法从构建中读取类，因此我通过扩展名传递了这些 JAR 文件 --JARS 。

这解决了我的问题。