java.sql.SQLException: Column count doesn't match value count at row 1 [Spark / Java /UPSERT]

Question

I'm trying to update values using JDBC on spark and I continue to get the same error .

I used the following query

 statement.addBatch(("INSERT INTO gasoil_summeries " + "VALUES ("
                        + "'" + row.getAs("id_vehicule2")+"'"
                         + "'" + row.getInt(0)+"'"
                        +"'" + row.getAs("litre2")+"'"
                        +"'" +row.getDouble(1)+"'"
                        + "'"+row.getAs("count2")+"'"
                        +"'" + row.getInt(2)+"'"
                        +"'" + row.getAs("is_sup2")+"'"
                        +"'"+row.getInt(3)+"'"
                        +"'" +row.getAs("last_upd2")+"'"
                        +"'"+row.getTimestamp(4)+"'"
                        +")  ON DUPLICATE KEY UPDATE _id_vehicule='" + row.getAs("id_vehicule2") + "';"));

the number of columns is the same, but I continue to get the error "java.sql.SQLException: Column count doesn't match value count at row 1"

Thnak you.

It seems that you need to join this dataframes. Can you provide your code? — andreoss
– andreoss, Commented Jul 1, 2020 at 8:53

user13597413 · Accepted Answer · 2020-07-06 10:42:57Z

I found the solution , maybe that can help someone .

 statement.addBatch(("INSERT INTO gasoil_summeries " + "VALUES ("
                        +"'" + row.getAs("id_vehicule2") + "'"+ ","
                         //"'" + row.getInt(0)+"'"+
                        +"'" + row.getAs("litre2")+ "'"+ ","
                       // +"'" +row.getDouble(1)+"'"+
                       + "'"+row.getAs("count2")+ "'"+ ","
                      //  "'" + row.getInt(2)+"'"+
                       +"'" + row.getAs("is_sup2")+ "'"+ ","
                     //   "'"+row.getInt(3)+"'"+
                       + "'" +row.getAs("last_upd2")+ "'"+
                      //  "'"+row.getTimestamp(4)+
                ")  ON DUPLICATE KEY UPDATE id_vehicule = '"+ row.getInt(0)+"',d_littre= '"+row.getDouble(1)+"',counter = '"+row.getInt(2)+"',is_suspect ='"+row.getInt(3)+"',last_update='"+row.getTimestamp(4)+ "' ; "));

Collectives™ on Stack Overflow

java.sql.SQLException: Column count doesn't match value count at row 1 [Spark / Java /UPSERT]

1 Answer 1

Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

Comments

Your Answer

Sign up or log in

Post as a guest

Related