sql >> Database >  >> RDS >> Mysql

Waarden invoegen in een tabel met dynamische kolommen Jdbc/Mysql

U kunt ook databasemetagegevens gebruiken om de kolomnamen te krijgen. Dit heeft als voordeel dat u de kolomnamen niet eens hoeft te weten, maar dynamisch in uw code wordt opgehaald.

public static List<String> getColumns(String tableName, String schemaName) throws  SQLException{

    ResultSet rs=null;

    ResultSetMetaData rsmd=null;
    PreparedStatement stmt=null;
    List<String> columnNames =null;
    String qualifiedName = (schemaName!=null&&!schemaName.isEmpty())?(schemaName+"."+tableName):tableName;
    try{
        stmt=conn.prepareStatement("select * from "+qualifiedName+" where 0=1");
        rs=stmt.executeQuery();//you'll get an empty ResultSet but you'll still get the metadata
        rsmd=rs.getMetaData();
        columnNames = new ArrayList<String>(); 
        for(int i=1;i<=rsmd.getColumnCount();i++)
            columnNames.add(rsmd.getColumnLabel(i));    
    }catch(SQLException e){
        throw e;//or log it
    }
    finally{
        if(rs!=null)
            try {
                rs.close();
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                throw e
            }
        if(stmt!=null)
            try {
                stmt.close();
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                throw e
            }
    }
    return columnNames;
}

Als je eenmaal de kolomnamen hebt, kun je deze gebruiken zoals je normaal zou doen (List.size() zou natuurlijk het aantal kolommen geven).

BIJWERKEN:

//I will assume that your values (data to be inserted) is a List of Object types and that it is already populated



List<Object> data = new ArrayList<>();
    //you will populate this list

    //getting the column names
    List<String> columnNames = getColumns("MyTable", "MyDB");

    String insertColumns = ""; 
    String insertValues = "";

    if(columnNames != null && columnNames.size() > 0){
        insertColumns += columnNames.get(0);
        insertValues += "?";
    }


    for(int i = 1; i < columnNames.size();i++){
      insertColumns += ", " + columnNames.get(i) ;
      insertValues += "?";
    }

    String insertSql = "INSERT INTO MyDB.MyTable (" + insertColumns + ") values(" + insertValues + ")"; 

    try{
    PrepareStatement ps = conn.prepareStatement(insertSql);

    for(Object o : data){
     ps.setObject(o); //you must pass objects of correct type
    }
    ps.execute(); //this inserts your data
    }catch(SQLException sqle){
      //do something with it
    }

Deze code gaat ervan uit dat u objecten van het juiste type doorgeeft aan de methode PreparedStatement.setObject(Object o). Het is ook mogelijk om kolomtypen op te halen met behulp van metadatabase-informatie en die informatie vervolgens te gebruiken om typecontrole af te dwingen, maar dat zou uw code veel gecompliceerder maken



  1. MySQL - alternatieven voor geneste subquery's bij het beperken van geaggregeerde gegevens in een gecorreleerde subquery

  2. twee woorden en lege spaties werken niet in MYSQL-query met LIKE

  3. Een reeks getallen genereren in MySQL

  4. Een SQL-query schrijven met dynamische LIMIT