Processing Forum

Attempting asynchronous communication between Arduino and Processing...it's not going well. :(

[3 Replies]
- 17-May-2012 02:05 PM
- Forum: Integration and Hardware
I've been basing both programs off of the SerialCallResponse example in Arduino 1.0 ( http://arduino.cc/en/Tutorial/SerialCallResponse ) to get them to talk. Perhaps it was never meant for something like this though.
In a nutshell, I want to first send 15 Arduino sensor values to Processing; then write 6 Processing values to the Arduino; lastly, I was looking to return those last 6 values to Processing to confirm that they were recorded.
Any advice or corrections would be greatly appreciated. I've been struggling with this for a bit now. At any rate here are the println responses generated through my debugging efforts:
Stable Library

=========================================

Native lib Version = RXTX-2.1-7

Java lib Version = RXTX-2.1-7

firstContact == false

inByte == 'A'

secondContact == false

thirdContact == false

didn't receive sensor data

goes on like this for a while

didn't receive sensor data

secondContact == false

thirdContact == false

138 //confirmation of the first value in the array received

serialCount == 15; 'Z' has been given to arduino; it should begin getData() now

secondContact == false

thirdContact == false

firstContact == false

inByte == 'A'

secondContact == false

thirdContact == false

didn't receive sensor data

goes on like this for a while

thirdContact == false

didn't receive sensor data

secondContact == false

inByte == 'B' + 'B'

thirdContact == false

didn't receive sensor data

secondContact == true

weather and preferences and 'Y' have been sent to arduino

thirdContact == false

didn't receive sensor data

secondContact == false

goes on like this for a while

thirdContact == false

didn't receive sensor data

secondContact == false

inByte == 'B' + 'B'

thirdContact == false

didn't receive sensor data

secondContact == true

weather and preferences and 'Y' have been sent to arduino

thirdContact == false

didn't receive sensor data

secondContact == false

goes on like this for a while

didn't receive sensor data

secondContact == false

thirdContact == false

didn't receive sensor data

secondContact == false

thirdContact == false

131

serialCount == 15; 'Z' has been given to arduino; it should begin getData() now

secondContact == false

thirdContact == false

firstContact == false

goes on like this for a while

thirdContact == false

firstContact == false

secondContact == false

inByte == 'B' + 'B'

thirdContact == false

firstContact == false

secondContact == true

weather and preferences and 'Y' have been sent to arduino

thirdContact == false

firstContact == false

secondContact == false

goes on like this for a while

secondContact == false

thirdContact == false

firstContact == false

secondContact == false

inByte == 'B' + 'B'

thirdContact == false

firstContact == false

secondContact == true

weather and preferences and 'Y' have been sent to arduino //it's odd that it's skipping

thirdContact == false

firstContact == false

secondContact == false

thirdContact == false

firstContact == false

secondContact == false

inByte == 'B' + 'B'

thirdContact == false

firstContact == false

secondContact == true

weather and preferences and 'Y' have been sent to arduino

thirdContact == false

firstContact == false

secondContact == false

inByte == 'B' + 'B'

thirdContact == false

firstContact == false

secondContact == true

weather and preferences and 'Y' have been sent to arduino

thirdContact == false

firstContact == false

secondContact == false

goes on like this for a while

thirdContact == false

firstContact == false

secondContact == false

inByte == 'B' + 'B'

thirdContact == false

firstContact == false

secondContact == true

weather and preferences and 'Y' have been sent to arduino

thirdContact == false

firstContact == false

keeps going until I kill the program

Code for both Arduino and Processing classes are here (password = Adaptive): http://robofacades.wordpress.com/code-hosting/acm11-facadeagent14/

Here is my processing code:

int[] serialInArray = new int[15]; // Where we'll put what we receive

int[] serialInArray3 = new int[6];

int serialCount = 0; // A count of how many bytes we receive

boolean firstContact = false; // Whether we've heard from the microcontroller

boolean secondContact = false;

boolean thirdContact = false;

void serialEvent(Serial comPort4){



int inByte = comPort4.read();



if (firstContact == false) {

delay(25);

println("firstContact == false");

if (inByte == 'A') {

comPort4.clear(); // clear the serial port buffer

firstContact = true; // you've had first contact from the microcontroller

comPort4.write('A'); // ask for more

delay(25);

println("inByte == 'A'");

}

}

else if (firstContact = true){

delay(25);

// Add the latest byte from the serial port to array:

serialInArray[serialCount] = inByte;

serialCount++;

if (serialCount > 14 ) { //reference to arduino values

//println("serialCount > 14");

intLightSens1 = serialInArray[0];

intLightSens2 = serialInArray[1]; //intLightSens1, intLightSens2, intLightSens3, avgInteriorLight, extLightSens1, extLightSens2, extLightSens3, extLightSens4, extLightSens5, solarPosition, actuatorPercent

intLightSens3 = serialInArray[2];

avgInteriorLight = serialInArray[3]; //temp_c_indoor 11, temp_f_indoor 12, dewpoint_f_indoor 13, relative_humidity_indoor 14

extLightSens1 = serialInArray[4];

extLightSens2 = serialInArray[5];

extLightSens3 = serialInArray[6];

extLightSens4 = serialInArray[7];

extLightSens5 = serialInArray[8];

solarPosition = serialInArray[9];

actuatorPercent = serialInArray[10];

temp_c_indoor = serialInArray[11];

temp_f_indoor = serialInArray[12];

dewpoint_f_indoor = serialInArray[13];

relative_humidity_indoor = serialInArray[14];

//comPort4.clear();

delay (50);

comPort4.write('Z');

firstContact = false; //reset boolean

serialCount = 0;

println(intLightSens1);

println("serialCount == 15; 'Z' has been given to arduino; it should begin getData() now");

}

else{

println("didn't receive sensor data");

}

}

if (secondContact == false) {

delay(25);

println("secondContact == false");

//comPort4.clear();

if (inByte == 'B' + 'B') {

comPort4.clear(); // clear the serial port buffer

secondContact = true; // you've had second contact from the microcontroller

comPort4.write('B' + 'B'); // ask for more

delay(25);

println("inByte == 'B' + 'B'");

}

}

else if (secondContact = true) {

delay(25);

comPort4.write(temp_f);

comPort4.write(relative_humidity);

comPort4.write(dewpoint_f);

comPort4.write(desiredInteriorLight);

comPort4.write(desiredIndoorHumidity);

comPort4.write(desiredIndoorTemp_f);



delay(25);

//comPort4.clear();

secondContact = false; //reset boolean

comPort4.write('Y');

serialCount = 0;

println("secondContact == true");

println("weather and preferences and 'Y' have been sent to arduino");

}

if (thirdContact == false) {

println("thirdContact == false");

if (inByte == 'C' + 'C' + 'C') {

comPort4.clear(); // clear the serial port buffer

thirdContact = true; // third contact from the microcontroller

comPort4.write('C' + 'C' + 'C'); // ask for more

delay(25);

println("inByte == 'C' + 'C' + 'C'");

}

}



else if (thirdContact == true) {

delay(25);

println("thirdContact == true");

serialInArray3[serialCount] = inByte;

serialCount++;

if (serialCount > 5 ) {

println (serialInArray3[0]);

println (serialInArray3[1]);

println (serialInArray3[2]);

println (serialInArray3[3]);

println (serialInArray3[4]);

println (serialInArray3[5]);

println("serialCount == 6; 'X' was sent and loop should restart");



//comPort4.clear();

delay (50);

comPort4.write('X');

serialCount = 0; // Reset serialCount

thirdContact = false; //reset boolean

}

else{

println("didn't receive serialInArray3 from arduino");

}

}

}

And the Arduino code:

//int inByte = 0;

//boolean secondContact = false;

//int serialInArray[6]; // Where we'll put what we receive

//int serialCount = 0; // A count of how many bytes we receive

void logData() {

Serial.read();

establishContact(); // send a byte to establish contact until receiver responds

if (Serial.available() > 0) {

//int writeSensorArray[] = {photoCell1, photoCell2, photoCell3, avgInteriorLight, photoCell4, photoCell5, photoCell6, photoCell7, photoCell8, solarPosition, actuatorPercent, temp_c_indoor, temp_f_indoor, relative_humidity_indoor, dewpoint_f_indoor};



Serial.write(photoCell1);

Serial.write(photoCell2);

Serial.write(photoCell3);

Serial.write(avgInteriorLight);

Serial.write(photoCell4);

Serial.write(photoCell5);

Serial.write(photoCell6);

Serial.write(photoCell7);

Serial.write(photoCell8);

Serial.write(solarPosition);

Serial.write(actuatorPercent);

Serial.write(temp_c_indoor);

Serial.write(temp_f_indoor);

Serial.write(relative_humidity_indoor);

Serial.write(dewpoint_f_indoor);

}



if (Serial.read() == 'Z'){

confirmReceipt();

getData();

}

if (Serial.read() == 'Y'){

confirmReceipt2();

delay(50);

confirmGetData();

}

if (Serial.read() == 'X'){

Serial.end();

}

}

void getData(){



int serialInArray[6] = {Serial.read()};



temp_f = serialInArray[0];

relative_humidity = serialInArray[1];

dewpoint_f = serialInArray[2];

desiredInteriorLight = serialInArray[3];

desiredIndoorHumidity = serialInArray[4];

desiredIndoorTemp_f = serialInArray[5];

}

void confirmGetData() {

Serial.write(temp_f);

Serial.write(relative_humidity);

Serial.write(dewpoint_f);

Serial.write(desiredInteriorLight);

Serial.write(desiredIndoorHumidity);

Serial.write(desiredIndoorTemp_f);

}

void establishContact() {

while (Serial.available() <= 0) {

Serial.print('A'); // send a capital A

delay(300);

}

}



void confirmReceipt() {

while (Serial.available() <= 1) {

Serial.write('B' + 'B'); // send a capital B

delay(300);

}

}

void confirmReceipt2() {

while (Serial.available() <= 2) {

Serial.print('C' + 'C' + 'C'); // send a capital C

delay(300);

}

}

Is a remote connection to Postgres DB using SQLibrary possible?

[4 Replies]
- 16-May-2012 09:21 AM
- Forum: Contributed Library Questions
In the PostgreSQL example for the SQLibrary ( http://bezier.de/processing/libs/sql/ ), it says that the example only works if the DB is on the local network. I can't seem to find anything in the documentation that suggests a way to differentiate the code to facilitate a remote-connection away from the local network.

Does anyone know if this can be done, or how?

PostgreSQL Example:
2. // updated fjenett 20081129
4. import de.bezier.data.sql.*;
7. PostgreSQL pgsql;
10. void setup()
11. {
12. size( 100, 100 );
14. // this example assumes that you are running the
15. // postgresql server locally (on "localhost").
16. //
18. // replace with your own postgresql-account.
19. //
20. String user = "fjenett";
21. String pass = "fjenett";
23. // name of the database to use
24. //
25. String database = "test";
27. // connect to database on "localhost"
28. //
29. pgsql = new PostgreSQL( this, "localhost", database, user, pass );
31. // connected?
32. if ( pgsql.connect() )
33. {
34. // query the number of entries in table "weather"
35. pgsql.query( "SELECT COUNT(*) FROM weather" );
37. // results found?
38. if ( pgsql.next() )
39. {
40. // nice, then let's report them back
41. println( "number of rows in table weather: " + pgsql.getInt(1) );
42. }
44. // now let's query for last 10 entries in "weather"
45. pgsql.query( "SELECT * FROM weather LIMIT 10" );
47. // anything found?
48. while( pgsql.next() )
49. {
50. // splendid, here's what we've found ..
51. println( pgsql.getString("city") );
52. }
53. }
54. else
55. {
56. // yay, connection failed !
57. }
58. }

Advice on using try() and catch() functions.

[6 Replies]
- 14-May-2012 10:14 AM
- Forum: Programming Questions
Hello,

I'm using Processing to read sensor values from an Arduino via com port. Everything seems to work fine for a couple of hours or so, but eventually one of the last values in the array String[] readList = splitTokens(getRawArduino); comes back null and causes a java.lang.ArrayIndexOutOfBoundsException at 11, 12, 13 or 14. Usually it happens at 11 though. The following variables are the source of the null values, and are all coming from the SHT15 temp/humidity sensor:
- temp_c_indoor = float(readList[11]);
- temp_f_indoor = float(readList[12]);
- dewpoint_f_indoor = float(readList[13]);
- relative_humidity_indoor = float(readList[14]);
Once in a while the sensor will return 0.0000 causing the null in processing. I'm trying to implement a try() and catch() function to deal with this, but I'm not understanding how it's set up and I'm hoping somebody can point out what I'm doing wrong.
2. void draw(){
4. if (lastQueryTime + 600000 > millis() && lastQueryTime < 100){
5. getXML();
6. doQueryExecuteDB();
7. lastQueryTime = millis();
8. }
10. if (arduinoCom + 120000 < millis()){
11. try{
12. nullException = readList.readArduino();
13. }
14. catch (ArrayIndexOutOfBoundsException) {
15. nullException = null;
16. }
17. if (nullException == null){
18. noLoop();
19. }
20. else{
21. readArduino();
22. }
23. writeArduino();
24. doWriteArduinoDB();
25. arduinoCom = millis();
26. }
28. if (lastQueryTime + 600000 < millis()) {
29. getXML();
30. doQueryExecuteDB();
31. lastQueryTime = millis();
32. }
33. }
2. void readArduino(){
4. //get the sensor and actuator data from the serial port
5. if (comPort4.available() > 0)
6. {
7. getRawArduino = comPort4.readString();
9. String[] readList = splitTokens(getRawArduino);
10. //convert strings to floats
11. intLightSens1 = int(readList[0]); // intLightSens1
12. intLightSens2 = int(readList[1]); // intLightSens2
13. intLightSens3 = int(readList[2]); // intLightSens3
15. avgInteriorLight = int(readList[3]); // avgInteriorLight
17. extLightSens1 = int(readList[4]); // extLightSens1
18. extLightSens2 = int(readList[5]); // extLightSens2
19. extLightSens3 = int(readList[6]); // extLightSens3
20. extLightSens4 = int(readList[7]); // extLightSens4
21. extLightSens5 = int(readList[8]); // extLightSens5
23. solarPosition = int(readList[9]); // solarPosition
24. actuatorPercent = int(readList[10]); // actuatorPercent
26. temp_c_indoor = float(readList[11]); // temp_c_indoor
27. temp_f_indoor = float(readList[12]); // temp_f_indoor
28. dewpoint_f_indoor = float(readList[13]); // dewpoint_f_indoor
29. relative_humidity_indoor = float(readList[14]); // relative_humidity_indoor
30. }
32. else{
33. println ("Not connected to Arduino");
34. }
35. }

Looking for method that projects variables into SQLibrary execute command.

[5 Replies]
- 07-May-2012 12:33 PM
- Forum: Programming Questions
Hello,

Is there a way to project updated values into a SQL command string? I'm accessing web-based XML data every ten minutes and want to write it to my PostgreSQL DB.

This would be the example command to write to DB:

pgsql.execute(INSERT INTO table (column1, column2, etc) VALUES (value1, value2, ect));

For these variables:

String station_location_xml;

String observation_time_xml;

String temp_f_xml;

String temp_c_xml;

String relative_humidity_xml;

String wind_degrees_xml;

String wind_dir_xml;

String wind_mph_xml;

String wind_gust_mph_xml;

String dewpoint_f_xml;

String dewpoint_c_xml;

I want to write into the DB, which could look like:

pgsql.execute( "INSERT INTO adaptive_weather_longterm (station_location, observation_time, temp_f, temp_c, relative_humidity, wind_dir, wind_mph, wind_gust_mph, dewpoint_f, dewpoint_c) VALUES ('" + station_location_xml + "', '" + observation_time_xml + "', '" + temp_f_xml + "', '" + temp_c_xml + "', '" + relative_humidity_xml + "', '" + wind_dir_xml + "', '" + wind_mph_xml + "', '" + wind_gust_mph_xml + "', '" + dewpoint_f_xml + "', '" + dewpoint_c_xml + "')");

Except, the library requires a straight up string here for "VALUES".

I've tried coding:

String sqlCommand = new String ("INSERT INTO adaptive_weather_longterm (station_location, observation_time, temp_f, temp_c, relative_humidity, wind_dir, wind_mph, wind_gust_mph, dewpoint_f, dewpoint_c) VALUES ('" + station_location_xml + "', '" + observation_time_xml + "', '" + temp_f_xml + "', '" + temp_c_xml + "', '" + relative_humidity_xml + "', '" + wind_dir_xml + "', '" + wind_mph_xml + "', '" + wind_gust_mph_xml + "', '" + dewpoint_f_xml + "', '" + dewpoint_c_xml + "')");

return (sqlCommand);

Then calling the variable:

pgsql.execute(sqlCommand);

However, I'm met with " Exception in thread "Animation Thread" java.lang.NullPointerException".

This is a problem since this data is not static. How can I get the dynamic values into this string???

Is there a new method I can add to the source?

Thanks in advance!

Can a DB be manipulated with SQLibrary?

[5 Replies]
- 06-May-2012 02:08 PM
- Forum: Programming Questions
I would like to write data to my PostgreSQL DB using SQLibrary.

First off, is it capable of doing that? I've had success querying the DB using this library, but there doesn't seem to be much documentation on writing to a DB using it. I've tried using pgsql.execute but get this error:

SQL.query(): java.sql.SQLException.

org.postgresql.util.PSQLException: ERROR: syntax error at end of input

at org.postgresql.core.v3.QueryExecutorImpl.receiveErrorResponse(QueryExecutorImpl.java:1608)

at org.postgresql.core.v3.QueryExecutorImpl.processResults(QueryExecutorImpl.java:1343)

at org.postgresql.core.v3.QueryExecutorImpl.execute(QueryExecutorImpl.java:194)

at org.postgresql.jdbc2.AbstractJdbc2Statement.execute(AbstractJdbc2Statement.java:451)

at org.postgresql.jdbc2.AbstractJdbc2Statement.executeWithFlags(AbstractJdbc2Statement.java:336)

at org.postgresql.jdbc2.AbstractJdbc2Statement.execute(AbstractJdbc2Statement.java:328)

at de.bezier.data.sql.SQL.execute(Unknown Source)

at dbQuery_XMLFeed.manipulateDB(dbQuery_XMLFeed.java:234)

at dbQuery_XMLFeed.draw(dbQuery_XMLFeed.java:56)

at processing.core.PApplet.handleDraw(Unknown Source)

at processing.core.PApplet.run(Unknown Source)

at java.lang.Thread.run(Thread.java:662)

The fact that it says "SQL.query():" leads me to think that this library only queries.

If it is possible, could someone provide an example?

Thanks in advance.

void manipulateDB(){

//query write start

size( 300, 300 );

// assumes that you are running the

// postgresql server locally (on "localhost").

//

// replace with your own postgresql-account.

//

String user = "user name";

String pass = "password";

// name of the database to use

//

String database = "db name";

// connect to database on "localhost"

//

pgsql = new PostgreSQL( this, "db address", database, user, pass );

// connected?

if ( pgsql.connect() )

{

pgsql.execute( "INSERT INTO adaptive_weather_longterm (station_location, observation_time, temp_f, temp_c, relative_humidity, wind_dir, wind_mph, wind_gust_mph, dewpoint_f, dewpoint_c) VALUES (station_location_xml, observation_time_xml, temp_f_xml, temp_c_xml, relative_humidity_xml, wind_dir_xml, wind_mph_xml, wind_gust_mph_xml, dewpoint_f_xml, dewpoint_c_xml");

}

else

{

//connection failed !

}

//query write end

}

Has anyone used XMLElement with JSON and/or Wundergourd.com?

[7 Replies]
- 01-May-2012 08:48 PM
- Forum: Contributed Library Questions
Hello,

I'm trying to parse XML weather data from wunderground.com using XMLElement, and it's looking like wunderground's API requires the use of JSON too.

Can anyone shed some light on how to make these come together?

The code below is junk, but I hope that it can give some idea of what I'm trying to accomplish.

import org.json.*;

XMLElement xml;

void setup() {

size(600, 600);

xmlElement xmlFeed = new XMLElement(this, "http://api.wunderground.com/weatherstation/WXCurrentObXML.asp?ID=KILCHICA30");

int numSites = xmlFeed.getChildCount();

for (int i = 0; i < numSites; i++) {

XMLElement current_observations = xml.getChild(i);

XMLElement[] kids = entry.getChildren();

//int id = kid.getInt("1"); //second node

float current_observation = int(kids[0].getContent());

string termp_f = string(kids[1].getContent());

//String url = kid.getString("http://api.wunderground.com/weatherstation/WXCurrentObXML.asp?ID=KILCHICA30");

//String site = kid.getContent();

println(id + " : " + url + " : " + site);

println(current_observation);

println(termp_f);

}

}

Advice on importing XML data from a URL and storing it on DB

[5 Replies]
- 30-Apr-2012 02:45 PM
- Forum: General Discussion
Hello,

I'm working on a project and I want to import XML data from a URL ( http://api.wunderground.com/weatherstation/WXCurrentObXML.asp?ID=KILCHICA30), then store it to tables on my postgreSQL server for immediate and later uses.

Additionally, I want the program to make certain decisions based on the data and send/receive data to an Arduino through the serial com port.

I'm not terribly concerned about the decision making methods that will take place in the app. It's the communication between program-URL and program-DB, as well as the conversion of XML that I'm unsure about. I would really appreciate any advice, or being pointed to the right resources.

Thanks!

Activity Trend